ListAzureDataLakeStorage 2025.10.2.19¶

ADLS 認証情報

Azure認証情報の取得に使用するController Service。

ファイルフィルター

指定された正規表現にマッチする名前のファイルだけがリストされます。

一時ファイルを含める

構成されたディレクトリパスの内容をリストする際に、仮のファイルを含めるかどうか。

最大ファイルサイズ

プルされるファイルの最大サイズ

最小ファイルサイズ

プルされるために必要なファイルの最小サイズ

サブディレクトリを再帰する

ディレクトリのサブディレクトリのファイルをリストするかどうかを示します。

et-state-cache

リストされたエンティティは指定されたキャッシュストレージに保存されるため、このプロセッサーは、NiFi 再起動時またはプライマリノードが変更された場合に、リストを再開できます。「エンティティの追跡」戦略では、直近の「追跡時間ウィンドウ」内にリストされているすべてのエンティティの追跡情報が必要です。多数のエンティティをサポートするために、この戦略では管理状態の代わりに DistributedMapCache を使用します。キャッシュキーの形式は「ListedEntities::{processorId}(::{nodeId})」です。ノードごとに列挙されたエンティティを追跡する場合は、状態を個別に管理するためにオプションの「::{nodeId}」部分が追加されます。例:クラスター全体のキャッシュキー =「ListedEntities::8dda2321-0164-1000-50fa-3042fe7d6a7b」、ノードごとのキャッシュキー =「ListedEntities::8dda2321-0164-1000-50fa-3042fe7d6a7b::nifi-node3」保存されるキャッシュの内容はGzip圧縮された JSON 文字列です。キャッシュキーは、ターゲットリスティングの構成が変更されると削除されます。「エンティティの追跡」戦略で使用されます。

listing-strategy

新規/更新エンティティの判定方法を指定します。詳しくは各戦略の説明をご覧ください。

record-writer

リストの作成に使用するRecord Writerを指定します。指定しない場合は、リストされたエンティティごとに FlowFile が1つ作成されます。Record Writerを指定すると、個々の FlowFiles に属性を追加する代わりに、すべてのエンティティが単一の FlowFile に書き込まれます。

CLUSTER

ファイルのリストをパフォーマンスした後、最も新しいファイルのタイムスタンプが保存されます。これにより、次回 Processor を実行したときに、この日付以降に追加または変更されたファイルのみがリストされます。状態はクラスタリングに保存され、このプロセッサーがPrimary Nodeで実行されます。新しいプライマリ・ノードが選択された場合、新しいノードはデータを複製することなく、前のノードが停止した場所を引き継ぐことができます。

success

受信したすべての FlowFiles は成功にルーティングされます。

azure.filesystem

Azure ファイルシステムの名前

azure.directory

Azureディレクトリの名前

azure.length

Azureファイルの長さ

azure.etag

Azure ファイルの ETag