概要
一部のシナリオでは、ログを異なるアカウントのログトピック間で移行および同期する必要があります。本記事では、Kafkaデータサブスクリプション機能を使用して、アカウントAのログトピックa内のログをアカウントBのログトピックbに同期する方法について説明します。
前提条件
操作手順
1. CLSコンソールにログインし、ログトピック管理ページで、移行または同期が必要なログトピックaを見つけ、ログトピックaの名前をクリックしてログトピックの詳細ページに移動します。 2. ログトピック詳細ページで、Kafkaプロトコル消費タブを見つけてクリックします。下図の通りです:
3. Kafkaプロトコル消費の現在の状態を有効にし、下図に従ってKafkaプロトコル消費を設定します(データ範囲は実際のビジネスシナリオに応じて決定します)。
4. 設定が完了したらOKをクリックします。すると、このログトピックがKafkaコンシューマーとしてのKafka Topic ID、Kafkaサービスドメインとして表示されます。Kafka Topic IDとKafkaサービスドメインを記録してください。
注意:
ログトピックaとログトピックbのリージョンが異なる場合は、外部ネットワークドメインを記録してください。リージョンが同じ場合は、内部ネットワークドメインを記録することをお勧めします。
5. ログトピックaが属するログセットを確認し、ログセットIDを記録してください。
6. APIキー管理に移動し、AアカウントのキーIDとキーKEYを確認して記録してください。 7. Bアカウントにログインし、移行または同期が必要なログトピックbを見つけ、ログトピックbの名前をクリックしてログトピックの詳細ページに移動します。
8. ログトピック詳細ページで、収集設定タブを選択し、Kafkaデータサブスクリプション設定の右側にある追加をクリックします。下図の通りです:
9. クラスタ設定手順で、下表の内容に従って設定します:
|
Kafkaクラスタタイプ | 自建 Kafkaを選択してください。 |
アクセス方法 | 公网访问を選択し、実際のシナリオに応じてイントラネットアドレスまたはパブリックアドレスを入力してください。パブリックサービスアドレスの入力ロジックは以下のとおりです。 ログトピックaとログトピックbのリージョンが異なる場合は、外部ネットワークアドレスを使用してください。 トピックaとトピックbが同じリージョンにある場合は、内部ネットワークアドレスを使用することをお勧めします。 |
サービスアドレス | a ログトピックのコンシューマー側の Kafka サービスドメイン(イントラネットアクセスの場合はイントラネットドメイン、パブリックアクセスの場合はパブリックドメインを入力します)。 |
認証の要否 | 対象Kafkaクラスタにアクセスするには認証が必要かどうかを指定します。 |
プロトコルタイプ | sasl_plaintextを選択してください。 |
認証メカニズム | PLAINを選択してください。 |
ユーザー名 | a ログトピックのログセット ID を入力してください。 |
パスワード | A アカウントキー ID#A アカウントキー KEY を入力します。 |
Kafka Topicリスト | a ログトピックのコンシューマー側の Kafka Topic ID を入力してください。 |
コンシューマーグループ | 空です。 |
開始位置 | 最晚を選択してください。 |
10. クラスタ設定が完了したら、プレビューをクリックして、ログトピックaのログが正常に消費されているかどうかを確認できます。
12. ログトピックbのKafkaデータサブスクリプションタスクの作成が完了すると、以下のログ検索分析、ダッシュボード、モニタリングとアラートなどの機能を使用できます。