データ・ストリーム

Oracle GoldenGateデータ・ストリームは、コミットされた変更レコードをOracle GoldenGate証跡から継続的に公開するWebSocketエンドポイントを提供します。クライアントは、名前付きデータ・ストリーム・リソースを作成または使用し、生成されたエンドポイントに接続し、JSONレコードを受信し、各レコードを処理して、最後に正常に処理されたリカバリ位置を保存します。

データ・ストリームでは、AsyncAPI 3.0ドキュメントを使用して、エンドポイント、チャネル、問合せパラメータ、メッセージ・シェイプおよびレコード・スキーマを記述します。特定のストリームに対して生成されたAsyncAPI YAMLは、そのストリームの認可契約です。別のデプロイメントから汎用ホスト名、チャネル・パスまたはペイロード定義をコピーするのではなく、これを使用します。

開発者とデータ・サイエンティストにとっての利点

• 拡張データ収集: AsyncAPIを搭載したパブリッシュ・モデルまたはサブスクライブ・モデルは、アプリケーションをリアルタイム・データ更新を効率的に受信できるようにします。

• 柔軟なデータ・フォーマット: 既存のツールとシームレスに統合するための優先フォーマットを選択できます。

• 合理化された統合: AsyncAPIは、開発者およびデータ・サイエンティストによって一般的に使用される様々なアプリケーションおよびツールとのスムーズな対話を促進します。

• 保証されたデータ整合性: Oracle GoldenGateのコア強度を継承するデータ・ストリームでは、ソース・データベースでコミットされた変更をレプリケートすることで、データの耐久性を確保します。

ノート:データ・ストリーム機能は、Oracle GoldenGate for Distributed Applications and AnalyticsまたはOracle GoldenGate for Big Data Targetsでライセンス付与されています。詳細は、Oracle GoldenGateライセンス・ガイドのOracle GoldenGate for Distributed Applications and Analyticsを参照してください。

ランタイム・シーケンス

1. Extractは、コミットされたソース変更を取得し、ローカルまたはリモートのOracle GoldenGate証跡に書き込みます。

2. 管理者は、ソース証跡とオプションのフィルタリングおよびJSON出力設定を識別するデータ・ストリーム・リソースを作成します。

3. このサービスは、データ・ストリームのAsyncAPI YAMLドキュメントを生成します。

4. クライアントは、WebSocket接続を確立し、begin=now、begin=earliest、ISO 8601タイムスタンプまたは保存されたpos値を提供します。

5. サービスはJSONメッセージを継続的にプッシュします。プロトコルは、クライアントからのレコードごとの確認を待機しません。

6. クライアントはレコードを処理し、最後に正常に処理されたDMLまたはDDLレコードからposを永続的に保存します。

サービスの送信内容

• ストリーム内のレコードを記述するJSONスキーマ・レコード。

• プロデューサ、ソース・データベース、ホストおよびソース証跡情報を識別するストリーム・メタデータ・レコード。

• 表の列、JSONプリミティブ型、nullabilityおよびキー・メンバーシップを記述するオブジェクト・メタデータ・レコード。

• INSERT、UPDATEおよびDELETEのDMLレコード。

• 影響を受けるオブジェクトを識別し、DDL文を含むDDLレコード。

• dataメンバーにGoldenGateレコードが含まれるオプションのCloudEvents JSONエンベロープ。