FetchDatabaseMetadata 2025.10.2.19¶
バンドル¶
com.snowflake.openflow.runtime | runtime-horizon-catalog-processors-nar
説明¶
すべてのテーブルの完全なデータベースメタデータを取得し、FlowFile に出力します。出力は、JSON の配列で、列名、データ型、メタデータなど、すべてのテーブルのデータベース情報とスキーマの詳細が含まれています。スキーマフェッチは、PostgreSQL、MySQL、SQL サーバーをサポートしています。SQL サーバーの場合、このプロセッサは適切な権限で接続すると、アクセス可能な ALL のデータベースからメタデータを取得することができます。PostgreSQL とMySQL については、接続されたデータベースからメタデータを取得します。出力フォーマット(データベースオブジェクトの配列): [ { "source": "<database_type>", "database_name": "<database_name>", "schemas": [ { "name": "<schema_name>", "entities": [ { "name": "<table_name>", "type": "table", "comment": "<table_comment>", "total_rows": <number_of_rows>, "columns": [ { "name": "<column_name>", "comment": "<column_comment>", "data_type": "<data_type>" } ], "created_on": <epoch_millis>, "updated_on": <epoch_millis> } ] } ] } ]注意:SQL サーバー接続の場合、接続が複数のデータベースにアクセスできる場合は、 配列には複数のデータベースオブジェクトが含まれます。PostgreSQL と MySQL の場合、配列には1つのデータベースオブジェクトが格納されます。テーブルと列のコメント、created_on、updated_onのタイムスタンプ、total_rowsは、データベースのメタデータから利用可能な場合は含まれますが、データベースシステムでサポートされていない場合は省略されることがあります。タイムスタンプはエポックミリ秒で表され、利用できない場合は-1となります。総行数は、データベース統計からの概算/推定値を表し(正確なカウントではありません)、権限やその他のデータベース固有の制限により決定できない場合は-1に設定されます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
接続プール |
スキーマ情報の取得に使用する接続プール |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
スキーマ情報が取得できない場合、FlowFiles はこの関係にルーティングされます |
テーブルが見つかりません |
アクセス可能なデータベースにテーブルがない場合、FlowFiles はこの関係にルーティングされます |
リトライ可能な失敗 |
スキーマ情報のフェッチに失敗した場合、FlowFiles はこの関係にルーティングされますが、操作を再試行すると成功する可能性があります |
success |
スキーマ情報の取得に成功すると、FlowFiles はこの関係にルーティングされます |
属性の書き込み¶
名前 |
説明 |
|---|---|
mime.type |
application/json |
dbms.type |
データベース管理システムの種類(DBMS)。例: |
database.count |
発見され処理されたデータベースの数 |
schema.count |
すべてのデータベースで見つかったスキーマの総数 |
table.count |
すべてのデータベースとスキーマで見つかったテーブルの総数 |