Microsoft Fabric EventstreamのExtractの追加

手順に従って、Microsoft Fabric Eventstreamソースを追加します。

開始する前に

次を確認します:

このソース接続タイプに固有の詳細を確認します。
ビッグ・データ・デプロイメント・コンソールで資格証明を作成します:
1. デプロイメントの詳細ページからビッグ・データ・デプロイメント・コンソールを起動し、ログインします。
2. 管理サービスの左側のナビゲーション・メニューで、「DB接続」を選択します。
3. 「DB接続」ページで、「資格証明の追加」(プラス・アイコン)を選択します。
4. 表示されるフィールドに次の詳細を入力し、「送信」を選択します。
  - 「資格証明ドメイン」に、OracleGoldenGateと入力します。
  - 「資格証明別名」に、kafkaと入力します。
  - 「ユーザーID」に、kafka://と入力します
  - 「パスワード」に、パスワードを入力します。
  - 「Verify Password」に、パスワードを再度入力します。

Extractの追加

OCI GoldenGateデプロイメント・コンソール・ナビゲーション・メニューで、「Extract」を選択します。
「Extract」ページで、「Extractの追加」を選択します。
「Extractの追加」パネルの「Extract情報」ページで、必要に応じて次のフィールドに入力し、「次へ」を選択します。
- 「プロセス名」に8文字以内で入力します。
- このプロセスと他のプロセスの区別に役立つ「説明」(オプション)を入力します。
- ドロップダウンから「ソース」を選択します。
「抽出オプション」ページで、必要に応じて次のフィールドに入力し、「次へ」を選択します。
1. 「Extract Trail」の場合:
  1. Extractプロセスの「名前」を入力します。
  2. サブディレクトリ名を入力して、生成された証跡ファイルのカスタムの場所を設定します。
  3. 「証跡順序」を入力して、証跡ファイルの開始番号を設定します。
  4. 「トレイル・サイズ」を入力して、生成されるトレイル・ファイルの最大サイズを設定します。
  5. 「暗号化プロファイル」を選択します。暗号化プロファイルが作成されていない場合は、デフォルトでローカル・ウォレット・プロファイルが選択されます。
  6. 「暗号化のアルゴリズム」を選択します。
    - なし
    - AES256
    - AES192
    - AES128
2. 「ソース資格証明」で、次を選択します:
  1. ドメイン
  2. 別名
  3. 開始する時期/場所
「管理対象オプション」ページで、必要に応じて次のオプション・フィールドに入力し、「次へ」を選択します。
- プロファイル名
- デプロイメントのヘルスに不可欠
- 自動開始
- 自動再起動
  
  ノート:プロファイルを追加し、「自動起動」および「自動再起動」オプションを構成すると、ネットワークの中断後にデプロイメントを自動的に再起動できます。詳細は、管理対象プロセスの構成を参照してください。
「パラメータ・ファイル」ページで、次を更新します。
1. SOURCEDB USERIDALIASをSOURCEDB USERIDALIAS kafka DOMAIN OracleGoldenGateに更新します。
2. 指定されたブートストラップ・サーバー内のすべてのトピックをリスニングするには、表マッピングをそのまま(TABLE source.*;)にします。指定されたトピックから取得するには、マッピングをTABLE source.<topic-name>;に変更します。ここで、<topic-name>は取得元のトピックの名前です。
  
  ノート: Extractマッピング形式はTable SourceSchema.Tableです。Kafkaには、ソース・スキーマ/テーブルはありません。OCI GoldenGateは、最初の部分(前述のステップのソース)をスキーマ名として、2番目の部分を表名として証跡ファイルに書き込みます。これにより、取得したkafkaメッセージを、サポートされている他のGoldenGateターゲットにレプリケートできます。
「作成および実行」を選択すると、Extractが作成および起動されます。「作成」を選択した場合は、後で「Extract」ページからExtractを手動で起動できます。