新規ファイルが作成または変更された場合のフローのトリガ

ファイル、FTP、および SFTP コネクタでは、ディレクトリをポーリングして、作成または更新されたファイルがないかどうかを確認するリスナ (Studio および Design Centerでは On New or Updated file と呼ばれる) が提供されます。見つかったファイルごとにメッセージが生成されます。

この機能の重要な部分は、ファイルが新規であることをどのように判別するかです。この判別には、次の 3 つの戦略があります。

  • autoDelete パラメータを true に設定する。この設定では、各ファイルは処理後に削除されるため、次回のポーリングで見つかったすべてのファイルが新規になります。

  • moveToDirectory パラメータを設定し、処理された各ファイルを処理後に別のディレクトリに移動する。この手順の効果は autoDelete と同じですが、ファイルは削除されません。

  • watermark パラメータを使用して、前回のポーリングの実行後に作成または更新されたファイルのみを選択する。

  • マッチャーを使用して、ファイルを絞り込む。

リスナ

リスナは FTP、SFTP、およびファイルコネクタで同様に機能します。ただし、各コネクタで使用する XML 要素は異なります。

例: SFTP リスナ (新規ファイルトリガ)
<flow name="onNewFile">
    <sftp:listener config-ref="file" directory="test-data/in" autoDelete="true">
      <scheduling-strategy>
        <fixed-frequency frequency="1000"/>
      </scheduling-strategy>
    </sftp:listener>

    <flow-ref name="processFile" />
</flow>

透かし

SFTP コネクタでは、透かしをアクティブ化または非アクティブ化できます。例を挙げます。

例: SFTP リスナを使用した透かし
<sftp:listener doc:name="On New File"
  watermarkEnabled="true"
  config-ref="SFTP_Config">
    <scheduling-strategy >
      <fixed-frequency />
    </scheduling-strategy>
</sftp:listener>

Was this article helpful?

💙 Thanks for your feedback!

Edit on GitHub