Database Migration Service (DMS) | ターゲットエンドポイントの作成 (Kafka) - AMS アドバンスト変更タイプリファレンス

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Database Migration Service (DMS) | ターゲットエンドポイントの作成 (Kafka)

kafka の Database Migration Service (DMS) ターゲットエンドポイントを作成します。

完全分類: デプロイ | 高度なスタックコンポーネント | Database Migration Service (DMS) | ターゲットエンドポイントの作成 (kafka)

変更タイプの詳細

変更タイプ ID

ct-1mrqxscu15apz

現在のバージョン

1.0

予想される実行期間

60 分

AWS の承認

必須

お客様の承認

不要

実行モード

自動

追加情報

Amazon MSK の AWS Database Migration Service ターゲットエンドポイントを作成する

AMS DMS は、Amazon Managed Streaming for Apache Kafka をターゲットエンドポイントとして使用できます。

AMS コンソールでのこの変更タイプのスクリーンショット:

AMS Advanced コンソール、RFC セクションの作成、ct-1mrqxscu15apz の変更タイプの詳細ボックス: Amazon MSK の AWS Database Migration Service ターゲットエンドポイントの作成。

仕組み:

  1. RFC の作成ページに移動します。AMS コンソールの左側のナビゲーションペインでRFCs をクリックして RFCsリストページを開き、RFC の作成をクリックします。

  2. デフォルトの変更タイプ参照ビューで一般的な変更タイプ (CT) を選択するか、カテゴリ別選択ビューで CT を選択します。

    • 変更タイプ別に参照: クイック作成エリアで一般的な CT をクリックすると、すぐに RFC の実行ページを開くことができます。クイック作成で古い CT バージョンを選択することはできません。

      CTs をソートするには、カードビューまたはテーブルビューですべての変更タイプ領域を使用します。どちらのビューでも、CT を選択し、RFC の作成をクリックして RFC の実行ページを開きます。必要に応じて、RFC の作成ボタンの横に古いバージョンで作成オプションが表示されます。

    • カテゴリ別に選択: カテゴリ、サブカテゴリ、項目、オペレーションを選択すると、CT 詳細ボックスが開き、必要に応じて古いバージョンで作成するオプションが表示されます。RFC の作成をクリックして、RFC の実行ページを開きます。

  3. RFC の実行ページで、CT 名エリアを開き、CT の詳細ボックスを表示します。件名は必須です (変更タイプの参照ビューで CT を選択した場合は入力されます)。追加設定エリアを開き、RFC に関する情報を追加します。

    実行設定領域で、使用可能なドロップダウンリストを使用するか、必要なパラメータの値を入力します。オプションの実行パラメータを設定するには、追加設定エリアを開きます。

  4. 完了したら、実行 をクリックします。エラーがない場合、RFC が正常に作成されたページに、送信された RFC の詳細と最初の実行出力が表示されます。

  5. Run parameters 領域を開き、送信した設定を確認します。ページを更新して RFC 実行ステータスを更新します。必要に応じて、RFC をキャンセルするか、ページ上部のオプションを使用してコピーを作成します。

仕組み:

  1. インライン作成 (すべての RFC と実行パラメータを含むcreate-rfcコマンドを発行) またはテンプレート作成 (2 つの JSON ファイルを作成し、1 つは RFC パラメータ用、もう 1 つは実行パラメータ用) のいずれかを使用し、2 つのファイルを入力としてcreate-rfcコマンドを発行します。どちらの方法もここで説明します。

  2. 返された RFC ID を使用して RFC: aws amscm submit-rfc --rfc-id ID コマンドを送信します。

    RFC: aws amscm get-rfc --rfc-id ID コマンドをモニタリングします。

変更タイプのバージョンを確認するには、次のコマンドを使用します。

aws amscm list-change-type-version-summaries --filter Attribute=ChangeTypeId,Value=CT_ID
注記

変更タイプのスキーマの一部であるかどうかにかかわらず、任意の RFC で任意のCreateRfcパラメータを使用できます。たとえば、RFC ステータスが変更されたときに通知を受け取るには、リクエストの RFC パラメータ部分 (実行パラメータではなく) --notification "{\"Email\": {\"EmailRecipients\" : [\"email@example.com\"]}}"にこの行を追加します。すべての CreateRfc パラメータのリストについては、AMS 変更管理 API リファレンスを参照してください。

インライン作成

インラインで指定された実行パラメータ (インラインで実行パラメータを指定する場合は引用符をエスケープ) を指定して create RFC コマンドを発行し、返された RFC ID を送信します。たとえば、コンテンツを次のような内容に置き換えることができます。

aws --profile saml --region us-east-1 amscm create-rfc --change-type-id "ct-1mrqxscu15apz" --change-type-version "1.0" --title "TestDMSTargetEndpointKafka" --execution-parameters "{\"Description\":\"TestKafkaTE\",\"VpcId\":\"VPC-ID\",\"Name\":\"KafkaTE-NAME\",\"StackTemplateId\":\"stm-knghtmmgefafdq89u"\",\"TimeoutInMinutes\":60,\"Parameters\":{\"EngineName\":\"kafka\",\"Broker": "BROKER-ID\"}}"

テンプレートの作成

  1. この変更タイプの実行パラメータを CreateDmsTeKafkaParams.json.

    aws amscm get-change-type-version --change-type-id "ct-1mrqxscu15apz" --query "ChangeTypeVersion.ExecutionInputSchema" --output text > CreateDmsTeKafkaParams.json
  2. 実行パラメータ JSON ファイルを変更して保存します。たとえば、コンテンツを次のような内容に置き換えることができます。

    { "Description": "Test description", "VpcId": "VPC-ID", "Name": "dmstargetsKafka", "StackTemplateId": "stm-knghtmmgefafdq89u", "TimeoutInMinutes": 60, "Parameters": { "EngineName": "kafka", "Broker": "BROKER-ID" } }
  3. JSON テンプレートを現在のフォルダ内のファイルに出力します。この例では CreateDmsTeKafkaRfc.json:

    aws amscm create-rfc --generate-cli-skeleton > CreateDmsTeKafkaRfc.json
  4. CreateDmsTeKafkaRfc.json ファイルを変更して保存します。たとえば、コンテンツを次のような内容に置き換えることができます。

    { "ChangeTypeVersion": "1.0", "ChangeTypeId": "ct-1mrqxscu15apz", "Title": "Kafka-DMS-Target-Endpoint" }
  5. RFC を作成し、実行パラメータファイルと CreateDmsTeKafkaRfc ファイルを指定します。

    aws amscm create-rfc --cli-input-json file://CreateDmsTeKafkaRfc.json --execution-parameters file://CreateDmsTeKafkaParams.json

    レスポンスで新しい RFC の ID を受け取り、それを使用して RFC を送信およびモニタリングできます。送信するまで、RFC は編集状態のままであり、開始されません。

実行入力パラメータ

実行入力パラメータの詳細については、「」を参照してください変更タイプ ct-1mrqxscu15apz のスキーマ

例: 必須パラメータ

{ "Description": "Test description.", "VpcId": "vpc-1234567890abcdef0", "Name": "dmstargets301", "StackTemplateId": "stm-knghtmmgefafdq89u", "TimeoutInMinutes": 60, "Parameters": { "EngineName": "kafka", "Broker": "ec2-12-345-678-901.compute-1.amazonaws.com:2345" } }

例: すべてのパラメータ

{ "Description": "Test description.", "VpcId": "vpc-317a9856", "Name": "dmstargets301", "StackTemplateId": "stm-knghtmmgefafdq89u", "TimeoutInMinutes": 60, "Parameters": { "EndpointIdentifier": "mykafkadmstarget", "EngineName": "kafka", "Broker": "ec2-12-345-678-901.compute-1.amazonaws.com:2345", "Topic": "kafka-default-topic" } }