データ移行または同期タスクを作成する前に、データソースを設定する必要があります。このトピックでは、データ伝送サービスを使用して RocketMQ データソースを作成する方法について説明します。
セキュリティリスク
データ伝送サービスのパブリック CIDR ブロックを自動または手動で追加することを選択できますが、セキュリティリスクが存在します。データ伝送サービスの使用は、発生する可能性のあるセキュリティリスクを理解し、認識していることを示します。アカウントに複雑なパスワードを設定する、CIDR ブロックのオープンポート番号を制限する、内部 API 間の通信の認証を有効にする、不要な CIDR ブロックを定期的にチェックして制限するなど、基本的なセキュリティ保護対策を講じる必要があります。
データ伝送サービスは、ビジネスニーズとセキュリティリスクに基づいて、ホワイトリストまたはセキュリティグループに自動的に追加された CIDR ブロックを追加または削除します。データ伝送サービス以外のビジネスニーズに、ホワイトリストまたはセキュリティグループの CIDR ブロックを使用しないでください。他のビジネスニーズにこのような CIDR ブロックを使用した場合、発生した問題はデータ伝送サービスの SLA の保証範囲外となります。データ伝送サービスのホワイトリストまたはセキュリティグループに IP アドレスを追加する方法の詳細については、「ホワイトリストを追加する」をご参照ください。
前提条件
データ伝送サービスには、クラウド リソースにアクセスする権限があります。詳細については、「データ伝送のロールに権限を付与する」をご参照ください。
RocketMQ インスタンスにグループを作成しました。詳細については、「グループを作成する」をご参照ください。
RocketMQ インスタンスに
oms_test_topicという名前の Topic を作成済みであること。RocketMQ インスタンスの [インテリジェント認証] アクセスコントロールタイプで [VPC での認証なし] を有効にしました。
[インテリジェント認証] は、RocketMQ インスタンスのデフォルトのアクセス制御タイプです。このモードでは、VPC 内の RocketMQ インスタンスに接続するクライアントはデフォルトで認証されます。 [VPC 内での認証不要] が無効になっている場合、VPC エンドポイントがデータソース接続テストに合格するには、RocketMQ インスタンスのユーザー名とパスワードが必要です。
制限事項
データ伝送サービスは、商用版とコミュニティ版を含む、バージョン 4.x および 5.x の RocketMQ インスタンスをサポートしています。
手順
にログインします
ApsaraDB for OceanBase コンソール左側のナビゲーションウィンドウで、[データ伝送] > [データソース管理] を選択します。
[データソース] セクションで、右上隅にある [新しいデータソース] をクリックします。
[新しいデータソース] ダイアログボックスで、[データソースの種類] に [RocketMQ] を選択します。
パラメーターを設定します。
パラメーター
説明
インスタンスタイプ
現在、[Alibaba Cloud RocketMQ インスタンス] オプションのみがサポートされています。
データソース識別子
数字と文字の組み合わせに設定することをお勧めします。スペースを含めることはできず、長さは 32 文字を超えることはできません。
クロス Alibaba Cloud アカウント
データ伝送サービスを使用すると、異なる Alibaba Cloud アカウントのインスタンス間でデータを移行または同期するタスクを設定できます。
ビジネスニーズに基づいて、このオプションを選択するかどうかを選択できます。このオプションを選択した場合は、ターゲットインスタンスの Alibaba Cloud アカウントを入力します。この Alibaba Cloud アカウントに対する権限がない場合は、最初に認証をリクエストしてください。詳細については、「クロスアカウント認証を申請する」をご参照ください。
インスタンス
データソース。ドロップダウンリストから Alibaba Cloud RocketMQ インスタンスを選択できます。
RocketMQ エンドポイント情報
RocketMQ データベースのエンドポイント。IP アドレス:ポート番号またはドメイン名:ポート番号の形式です。
AccessKey
ID 認証のために RAM (Resource Access Management) コンソールで作成した AccessKey ID。
ページの右上隅にあるユーザーアバターにカーソルを合わせ、 [AccessKey の管理] をクリックして AccessKey ID を表示できます。
SecretKey
ID 認証のために RAM コンソールで作成した AccessKey シークレット。
AccessKey シークレットは、最初に作成したときに一度だけ表示されます。AccessKey シークレットを忘れた場合は、取得できません。後で使用する AccessKey シークレットを保存することをお勧めします。詳細については、「AccessKey ペアを作成する」をご参照ください。
備考 (オプション)
データソースに関する追加情報。
[接続テスト] をクリックして、データ伝送システムとソースデータベース間のネットワーク接続をテストします。
重要oms_test_topicTopic を作成しない場合、テストは失敗します。テストに合格したら、[OK] をクリックします。
グループを作成する
RocketMQ データソースを作成する前に、事前に defaultGroup を作成する必要があります。そうしないと、接続テストは失敗します。
RocketMQ インスタンスの詳細ページに移動します。
Message Queue for Apache RocketMQ コンソール にログインします。
左側のナビゲーションウィンドウで、[インスタンス] をクリックします。
インスタンスリストで、ターゲットインスタンスの名前をクリックします。 [インスタンス] ページが表示されます。
左側のナビゲーションウィンドウで、[グループ] をクリックします。
[グループ] ページで、[グループの作成] をクリックし、パラメーターを設定します。
RocketMQ インスタンスのバージョンによって、グループの作成時に設定が必要なパラメーターが異なります。詳細については、「グループを管理する」をご参照ください。
重要グループを作成するときは、グループ ID を defaultGroup に設定する必要があります。
パラメーターを設定した後、 [OK] をクリックします。
oms_test_topic という名前のトピックを作成します。
インスタンスの詳細ページで、左側のナビゲーションウィンドウの [トピック] をクリックします。
[トピック] ページで、[トピックの作成] をクリックします。
[トピックの作成] ダイアログボックスで、パラメーターを設定します。
パラメーター
説明
名前
このパラメーターを oms_test_topic に設定します。
課金方法
このパラメーターは、バージョン 4.x の RocketMQ インスタンスでのみ使用でき、[従量課金制] のみをサポートしています。
メッセージタイプ
バージョン 4.x の RocketMQ インスタンスは、[標準メッセージ]、[トランザクションメッセージ]、[パーティション順序付けメッセージ]、[グローバル順序付けメッセージ]、[スケジュール/遅延メッセージ] をサポートしています。
バージョン 5.x の RocketMQ インスタンスは、[標準メッセージ]、[順序付けメッセージ]、[スケジュール/遅延メッセージ]、[トランザクションメッセージ] をサポートしています。
説明
最大 128 文字まで含めることができます。
パラメーターを設定した後、 [OK] をクリックします。