ListTableNames 2025.10.2.19

バンドル

com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar

説明

すべてのソーステーブル名を取得し、可能な構成の1つと一致させます: -正規表現式(例: "(?i)customer.(orders|payments)")- 大文字と小文字を区別せずに名前と一致します。これは、「CUSTOMER.ORDERS」と「customer.orders」ソーステーブル名の両方に一致します。- カンマ区切りのソーステーブル名のリスト。例:「customer.orders, customer.payments」ソーステーブル名は大文字と小文字を区別して一致します。つまり、「customer.orders」ソーステーブルは MATCH 関係に転送されますが、「customer.ORDERS」は一致しません。複製できない一致したソーステーブルは、属性に理由が含まれた、個別の FlowFile 内の各テーブルで FAILURE 関係にルーティングされます。構成は FlowFile 属性として渡されます。ソーステーブル名は、<schema_name>.<table_name> のように表されるので、両方の入力はそれを考慮する必要があります。一致したソーステーブル名は MATCHED 関係に転送されます。プロセッサーは、一致するテーブルを持つ単一の FlowFile を生成します。免責事項: Postgresqlでは、大文字と小文字を区別する方法と区別しない方法でデータベースオブジェクト名を定義することができます。ユーザーが次のクエリ「CREATE TABLE ORDERS(id int not null)」を使用してテーブルを作成した場合、Postgresql内部では小文字(orders)を使用して保存されます。大文字と小文字を区別するには、テーブル名を二重引用符で囲む必要があります。(例:「CREATE TABLE"ORDERS"(id int not null)」これは、複製したいテーブルを設定する際に重要な点です。

タグ

入力要件

REQUIRED

機密動的プロパティをサポート

false

プロパティ

プロパティ

説明

接続プール

データベースへの接続を取得するために使用するController Service。

カンマ区切りのソース・テーブル名を含む

複製するテーブルのカンマ区切りのリスト。単一のテーブルは、<schema_name>.<table_name> のようにフォーマットする必要があります。例: customer.orders、customer.payment。これを正規表現と組み合わせることで、一致するテーブルをすべて含めることができます。

含まれるソーステーブルパターン

複製するテーブル名を指定する正規表現例: customer.(orders|payments)これはカンマ区切りのリストと組み合わされ、一致するテーブルが含まれます。

リレーションシップ

名前

説明

failure

FlowFile 属性が読み取れないか、間違っている場合、このリレーションシップにルーティングされます。

matched

FlowFile の作成に成功しました。ソース・データベースで一致するテーブルのリストが見つかりました。

属性の書き込み

名前

説明

source.schema.name

イベントの発生元テーブルのスキーマ名

source.table.name

イベントの発生元テーブル名

source.entry

テーブル名を処理する際に解析しようとした元のエントリ

reason

テーブルが複製できない理由

source.database.version.major

ソース・データベースのメジャー・バージョン。

mime.type

FlowFile コンテンツの MIME 型。