FTP および SFTP Connector への移行
SFTP および SFTP トランスポートは一新されました。Mule 3 のトランスポートモデルから、操作ベースのコネクタに進化しています。このため、多数の新しい機能が可能になります。
-
インバウンドエンドポイントでしかポーリングされなかった旧来のトランスポートとは異なり、オンデマンドでファイルを読み込むことや、ディレクトリのコンテンツの完全リストを作成することができる。
-
ファイルシステムの一般的な操作 (コピー、移動、名前変更、削除、ディレクトリの作成など) を最大限サポートする。
-
ファイルシステムレベルでファイルのロックをサポートする。
-
ファイルマッチング機能が向上する。
さらに、これらは完全対称になるよう設計されています。つまり、接続設定を除き、デザインや動作が同様で、まったく同じ機能セットを備えています。また、File Connector の機能や動作にも適合します。
FTP または SFTP サーバーへの接続
FTP 接続の移行
<ftp:inbound-endpoint host="localhost"
port="21" path="path/to/file"
user="myusername" password="maypassword"
pollingFrequency="4000" responseTimeout="10000" metadata:id="5571009e-a278-4a01-ac1d-4102113b52ad"
doc:name="FTP">
<reconnect-forever frequency="3000"/>
</ftp:inbound-endpoint>次の例は、Mule 4 のシンプルな FTP 設定を示しています。
<ftp:config name="ftp">
<ftp:connection username="anonymous"
password="password" host="localhost"
port="${ftpPort}" workingDir="${workingDir}"/>
</ftp:config>SFTP 接続の移行
<sftp:inbound-endpoint host="localhost"
port="22" path="path/to/file"
user="myuser" password="mypassword"
responseTimeout="10000"
pollingFrequency="2000" fileAge="50"
sizeCheckWaitTime="10" doc:name="SFTP"/><sftp:config name="sftp">
<sftp:connection username="myusername"
password="mypassword"
host="localhost"
port="${sftpPort}"
workingDir="${workingDir}"/>
</sftp:config>SFTP 接続はプロキシ経由の接続もサポートしています。
<sftp:config name="sftp">
<sftp:connection username="muletest1" password="muletest1"
host="127.0.0.100" port="${SFTP_PORT}" workingDir="${workingDir}">
<sftp:sftp-proxy-config host="localhost" port="${proxyPort}" protocol="HTTP"/>
</sftp:connection>
</sftp:config>インバウンドエンドポイントの移行
Mule 3 では、<ftp:inbound-endpoint> と <sftp:inbound-endpoint> メッセージソースを使用してファイルのディレクトリをポーリングしていました。ファイルが検出されるごとにい、新しいメッセージがトリガーされました。このメッセージには、ペイロード内にファイルのコンテンツが保持され、多数のファイル属性がシステムプロパティとして示されていました。同じファイルが何度も選択されることがないように、autoDelete と moveTo パラメーターが用意され、ファイルが選択されるとポーリング対象のディレクトリから削除されていました。
Mule 4 ではこの方法が改良されています。<ftp:listener> と <sftp:listener> コンポーネント (Studio パレットでは On New File と表示) がディレクトリをポーリングし、以前と同様のやり方で新しいメッセージをトリガーします。ただし、次の機能が追加されています。
-
<ftp:matcher> と <sftp:matcher> を使用して、特定の条件に一致するファイルのみを受け取ることができます。 -
ファイルを強制的に削除または移動する必要がなくなりましたが、この操作を行うオプションは引き続き使用できます。
-
コネクタのいずれかの操作を使用して、処理されたファイルが条件に一致しなくなるように変更できます。
-
ウォーターマークは自動的にサポートされ、必要に応じてファイルのタイムスタンプに基づいて自動的に絞り込むことができます。
<flow name="listener">
<ftp:inbound-endpoint address="ftp://anonymous:password@localhost:${port1}"
pollingFrequency="1000"/>
<flow-ref name="processFile" />
</flow><ftp:config name="ftp">
<ftp:connection host="localhost" user="anonymous" password="password" workingDir="${workingDir}"/>
</file:config>
<flow name="listenWithScheduler" initialState="stopped">
<ftp:listener config-ref="ftp" directory=".">
<scheduling-strategy>
<fixed-frequency frequency="1000"/>
</scheduling-strategy>
</file:listener>
<flow-ref name="processFile" />
</flow>アウトバウンドエンドポイントの移行
Mule 3 のトランスポートは <ftp:outbound-endpoint> コンポーネントを使用して、現在のペイロードをファイルに書き込みます。Mule 4 のコネクタは、その代わりに <ftp:write> 操作を使用します。
特に重要な違いは次のとおりです。
-
<ftp:outbound-endpoint> は、実行時にメッセージペイロードに書き込むコンテンツが必要でした。<ftp:write> 操作では、書き込むコンテンツを生成する DataWeave 変換を組み込むことができます。 -
Mule 3 のトランスポートでは設定レベルで
outputAppend パラメーターが設定されるのに対し、<ftp:write> 操作には mode パラメーターがあります。
<ftp:connector name="file" outputAppend="true" />
<flow name="greetings">
<http:listener path="greet" method="POST"/>
<set-payload value="Hello #[payload.name]" />
<ftp:outbound-endpoint path="greet.txt" connector-ref="file" />
</flow><flow name="greetings">
<http:listener path="greet" method="POST"/>
<ftp:write path="greet.txt" mode="APPEND">
<ftp:content>#['Hello $(payload.name)']</file:content>
</file:write>
</flow>SFTP Connector で FTP を使用するには、Studio パレットを使用してアプリケーションに追加するか、次の連動関係を pom.xml ファイルに追加します。
<dependency>
<groupId>org.mule.connectors</groupId>
<artifactId>mule-ftp-connector</artifactId>
<version>1.1.0</version> <!-- or newer -->
<classifier>mule-plugin</classifier>
</dependency>
<dependency>
<groupId>org.mule.connectors</groupId>
<artifactId>mule-sftp-connector</artifactId>
<version>1.1.0</version> <!-- or newer -->
<classifier>mule-plugin</classifier>
</dependency>SFTP アウトバウンドの「addSeqNo」の重複処理
Mule 3 で duplicateHandling="addSeqNo" を使用すると、未使用のインデックスが見つかるまでファイル名に反復処理が行われます。
Mule 4 では、オブジェクトストアや UUID などを使用して、このコードを独自のインデックスに置換する必要があります。
addSeqNo<flow name="sftpSeqNumberOutbound">
<sftp:outbound-endpoint
address="sftp://.../data"
outputPattern="fileName.dat" duplicateHandling="addSeqNo"/>
</flow>path に uuid() が設定された sftp:write<flow name="sftpSeqNumberOutbound">
<sftp:write config-ref="sftpConfig" path="#['data/fileName_' ++ uuid() ++ '.dat']"/>
</flow>SFTP の tempDir の移行
Mule 3 の SFTP トランスポートでは、ファイルの読み取りまたは書き込み時に使用する一時的なディレクトリを設定できます。この設定で指定するプロパティは次のとおりです。
-
sftp:connector:-
tempDirInbound -
tempDirOutbound -
useTempFileTimestampSuffix
-
-
sftp:inbound-endpoint:-
tempDir -
useTempFileTimestampSuffix
-
-
sftp:outbound-endpoint:-
tempDir -
useTempFileTimestampSuffix
-
Mule 4 の SFTP Connector ではこれらの設定を使用できません。ただし、このコネクタには、この種の設定の代わりとなる sftp:move 操作があります。
tempDir<flow name="sftpListener">
<sftp:inbound-endpoint address="sftp://.../testdir"
tempDir="tmp_sending" useTempFileTimestampSuffix="true"/>
...
</flow>sftp:move<flow name="sftpListener">
<sftp:listener config-ref="sftpConfig" directory="testdir"/>
<!-- This DataWeave generates the same filename as the Mule 3 transport when using the tempDir attribute -->
<sftp:move config-ref="sftpConfig" sourcePath="#['testdir/' ++ attributes.name]" targetPath="#['tmp_sending/' ++ joinBy(flatMap(splitBy(attributes.name, '.'), (item, index) -> (if (index == 0) item ++ '_' ++ now() as String{format: 'yyyyMMddHHmmssSSS'} else item)), '.')]"/>
...
</flow>ローカルドライブへのファイルのアーカイブ
Mule 4 で、SFTP Connector のリスナーの moveToDirectory 属性では、ローカルディレクトリではなく SFTP サーバーの別のディレクトリにのみアーカイブします。
File Connector で Write 操作 (file:write) を使用すれば、ファイルをローカルドライブにアーカイブできます。
file:write<flow>
<sftp:listener path="/a/b" />
<file:write path="#['archive/$(attributes.fileName})']" />
<flow-ref name="theRestOfYourIntegration" />
</flow>