Openflowコネクタダッシュボードを使用したコネクタのモニター¶

コネクタのフィルタリング¶

Openflowコネクタダッシュボードは、次のフィルタをサポートしています。

Event table

モニターしたいOpenflowコネクタのイベントテーブル。このフィルターは、デフォルトのイベントテーブルとアカウントイベントテーブルだけでなく、少なくとも1つのOpenflowデプロイメントに関連付けられたイベントテーブルを表示します。一度に選択できるイベントテーブルは1つだけです。イベントテーブルビューもサポートされています。

イベントテーブルは、Openflowを設定すると設定されます。

Tip

Openflowのデプロイに関連するイベントテーブルを表示するには、 DESCRIBE OPENFLOW DATA PLANE INTEGRATION コマンドを使用します。イベントテーブルの構成の詳細については、 :doc:` Openflowの設定： Snowflakeのデプロイ</user-guide/data-integration/openflow/setup-openflow-spcs-deployment>` または Openflowの設定 - BYOC をご参照ください。

時間枠

このフィルターを使用して、特定の時間枠にある関連コネクタを識別します。

Tip

コネクタの健全性に関する最新の結果を取得するには、 Last Hour 期間を選択します。

Status

Healthy、 Unhealthy または All コネクタのフィルタリングを有効にします。

Source

既知のデプロイ済みコネクタに基づいて、ソースシステムによるフィルタリングを有効にします。フィルターには、コネクタで使用されるソースのみが表示されます。

Deployment

Snowflake Openflowのデプロイによるフィルタリングを有効にします。

このフィルターは、 OPENFLOW_DATAPLANE_ という接頭辞に続いてデプロイ ID で構成されるデータプレーン統合名を表示します。デプロイ ID を見つけるにはOpenflowに移動し、 Deployments タブを選択し、次に View Details を選択します。

Runtime

Snowflake Openflowランタイムによるフィルタリングを有効にします。

このフィルターはランタイムキーを表示します。UI でランタイムキーとOpenflowランタイム名を一致させるには、Openflowに移動し、 Runtimes タブを選択し、次に View Details を選択して対応するキーを見つけます。

Type

コネクタタイプによるフィルタリングを有効にします。データベース、 SaaS、ストリーミング、非構造化、その他。

変更データキャプチャコネクタ¶

詳細ページには、変更データキャプチャ構成の一部である各テーブルの次の情報が表示されます。

Table replication status

テーブルは Active または Failed 複製ステータスのいずれかになります。複製ステータスは、テーブルで使用可能な最新のテレメトリーイベントに基づいています。テーブルの複製に失敗するイベントが発生した場合、ダッシュボードには即座に Failed 複製ステータスが表示されます。問題を特定するには Failure Reason メッセージを使用します。

Error distribution

コネクタに問題が発生した時期を理解して、ソースシステム、コネクタの構成、またはSnowflakeの宛先に潜在的な問題を特定できるようにします。

Table name

コネクタによって複製されるように構成されているすべてのテーブルのスキーマとテーブル名を表示します。リストはコネクタの Included Table Names または Included Table Regex 構成パラメーターに一致します。

Replication status

各テーブルが Active または Failed 複製ステータスにあるかどうかを示します。

Replication phase

現在のテーブル複製フェーズを表示します。コネクタでの構成後、テーブルは New 複製フェーズに入り、 Snapshot Load フェーズに進行し、初期ロードを実行、個々の変更データキャプチャイベントが処理されると最終的に Incremental Replication フェーズに入ります。

Last Ingested

選択した時間枠中に宛先テーブルに最後に挿入された記録のタイムスタンプを表示します。このメトリックを見るときは、記録がインジェストされてから、イベントがログに記録されてクエリに使用可能になるまでの短い遅延を考慮してください。

テーブルリストを絞り込むには Replication status、 Replication phase、時間枠フィルターを使用できます。

すべてのコネクタ¶

Connector status

コネクタの健全性ステータスを表示します。選択した時間枠中にエラーメッセージが発生しなかった場合は Healthy 、エラーメッセージが発生した場合は Unhealthy。

Error distribution

選択した期間中にこのコネクタが発生したエラーの数を表示します。

Average throughput

選択したコネクタについてソースシステムからデータが読み込まれ、Snowflakeに取り込まれる速度を測定します。

• Average throughput`|raa|:ui:`Ingested メトリックは、選択したコネクタがSnowflakeにデータを取り込む速度を測定します。

• Average throughput`|raa|:ui:`Read メトリックは、選択したコネクタがソースシステムからデータを読み取る速度を測定します。

Total data ingested

選択した期間中に選択したコネクタがSnowflakeに取り込んだデータの量を表示します。このメトリックを使用して、特定の期間におけるインジェスチョンの異常をすばやく特定します。

カスタムフロー¶

Openflowキャンバス上に構築されたカスタムフローは、ダッシュボード上でも監視できますが、Openflow Git統合を使用して、顧客のGitリポジトリでアクティブにバージョン管理されている場合のみです。バージョン管理されていないフローはダッシュボードには表示されません。

詳細については、 カスタムフローのバージョン管理 をご参照ください。

コネクタエラーの表示¶

選択した時間枠内にコネクタで発生したすべてのエラーを表示するには、まず |vertical-more-icon||raa|View Details を選択してコネクタの詳細ページに移動し、次に Issues タブを選択します。

エラータイトルはコネクタで発生したエラーの種類を示し、コンテンツはエラーのスタックトレース全体を提供します。

コネクタログの表示¶

また、追加のコネクタログを参照して、エラーメッセージの前後のコンテキストを理解することもできます。選択したコネクタのすべてのログを表示するには、 |vertical-more-icon||raa|View logs を選択します。

ログエクスプローラーを開いた後、フィルターを変更して、異なるコネクタまたはランタイムまたはデプロイ全体のログを表示することもできます。ログエクスプローラーは、データプレーン ID、ランタイムキー、プロセスグループ ID のようなOpenflow固有のフィルターをサポートします。

Openflowキャンバスへのアクセス¶

コネクタの問題を特定した場合、それを修正するためにOpenflowキャンバスに移動する必要があります。たとえば、いくつかの構成パラメーターを調整したり、新しいコネクタバージョンにアップグレードしたりします。

Openflowキャンバスで選択したコネクタに移動するには、 |vertical-more-icon||raa|Go to canvas を選択します。

より大きなウェアハウスを選択します¶

画面右上のウェアハウスセレクターを使用して、クエリを実行する別のウェアハウスを選択します。

Openflowイベントテーブルでクラスタリングを設定する¶

このクラスタリングキーを活用して、クエリ中のマイクロパーティションの不要なスキャンを回避し、これらの列を参照するクエリのパフォーマンスを大幅に向上させます。詳細については、 データクラスタリングとは をご参照ください。

プレースホルダーをOpenflowイベントテーブルに置き換えて、以下のクエリを実行します。

ALTER TABLE <database>.<schema>.<event_table_name>
  CLUSTER BY (
    DATE_TRUNC('HOUR', timestamp),
    RECORD_TYPE,
    CAST(record_attributes:"metricNameHash" AS STRING)
  );

クエリ時間枠を短縮¶

フィルターでより小さい時間枠を選択すると、スキャンされるデータが少なくなり、クエリのパフォーマンスが向上します。コネクタの健全性とパフォーマンスに関する最新の情報と最高のパフォーマンスを得るには、 Last Hour フィルターを使用してください。