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)。例: POSTGRESQL

database.count

発見され処理されたデータベースの数

schema.count

すべてのデータベースで見つかったスキーマの総数

table.count

すべてのデータベースとスキーマで見つかったテーブルの総数