すべてのプロダクト
Search

このプロダクト

    ApsaraMQ for Kafka:簡易 Log Service シンクコネクタを作成する

    ドキュメントセンター

    ApsaraMQ for Kafka:簡易 Log Service シンクコネクタを作成する

    最終更新日:Feb 18, 2025

    このトピックでは、ApsaraMQ for Kafka インスタンスのトピックから簡易 Log Service にデータをエクスポートする簡易 Log Service シンクコネクタを作成する方法について説明します。

    前提条件

    前提条件については、「前提条件」をご参照ください。

    ステップ 1：簡易 Log Service リソースを作成する

    この例では、guide-sls-sink-project という名前のプロジェクトと guide-sls-sink-logstore という名前のログストアが作成されます。

    ステップ 2：簡易 Log Service シンクコネクタを作成して開始する

    1. ApsaraMQ for Kafka コンソール にログインします。リソースの分布 セクションの 概要 ページで、管理する ApsaraMQ for Kafka インスタンスが存在するリージョンを選択します。

    2. 左側のナビゲーションウィンドウで、Connector エコシステムの統合 > [タスク] を選択します。

    3. [タスク] ページで、[タスクの作成] をクリックします。

      • タスクの作成

        1. Source (ソース) ステップで、データプロバイダー パラメーターを [apsaramq For Kafka] に設定し、画面の指示に従って他のパラメーターを設定します。次に、[次のステップ] をクリックします。次の表にパラメーターを示します。

          パラメーター

          説明

          例

          リージョン

          ApsaraMQ for Kafka インスタンスが存在するリージョン。

          中国 (北京)

          Apsaramq For Kafka インスタンス

          ルーティングするメッセージが生成される ApsaraMQ for Kafka インスタンス。

          MQ_INST_115964845466****_ByBeUp3p

          トピック

          ルーティングするメッセージが生成される ApsaraMQ for Kafka インスタンスのトピック。

          topic

          グループ ID

          ApsaraMQ for Kafka インスタンスのコンシューマーグループの名前。メッセージルーティングソースを作成するには、別のコンシューマーグループを使用する必要があります。使用中のコンシューマーグループは使用しないでください。そうしないと、既存のメッセージの送受信に失敗する可能性があります。

          GID_http_1

          コンシューマーオフセット

          メッセージが消費されるオフセット。

          最新のオフセット

          ネットワーク設定

          メッセージをルーティングするネットワークのタイプ。

          ベーシックネットワーク

          VPC

          ApsaraMQ for Kafka インスタンスがデプロイされている仮想プライベートクラウド (VPC) の ID。[ネットワーク設定] パラメーターを セルフマネージドインターネット に設定した場合にのみ、このパラメーターが必要です。

          vpc-bp17fapfdj0dwzjkd****

          vSwitch

          ApsaraMQ for Kafka インスタンスが関連付けられている vSwitch の ID。[ネットワーク設定] パラメーターを セルフマネージドインターネット に設定した場合にのみ、このパラメーターが必要です。

          vsw-bp1gbjhj53hdjdkg****

          セキュリティグループ

          ApsaraMQ for Kafka インスタンスが属するセキュリティグループ。[ネットワーク設定] パラメーターを セルフマネージドインターネット に設定した場合にのみ、このパラメーターが必要です。

          alikafka_pre-cn-7mz2****

          一括プッシュの件数

          関数呼び出しごとに送信できるメッセージの最大数。リクエストは、バックログ内のメッセージ数が指定された値に達した場合にのみ送信されます。有効な値：1 ～ 10000。

          100

          バッチプッシュ間隔 (単位：秒)

          関数が呼び出される時間間隔。システムは、指定された時間間隔で集約されたメッセージを Function Compute に送信します。有効な値：0 ～ 15。単位：秒。値 0 は、集約後すぐにメッセージが送信されることを指定します。

          3

        2. Filtering (フィルタリング) ステップで、パターン内容 コードエディターでデータパターンを定義して、リクエストをフィルタリングします。詳細については、「イベントパターン」をご参照ください。

        3. Transform (変換) ステップで、データクレンジングメソッドを指定して、分割、マッピング、エンリッチメント、動的ルーティングなどのデータ処理機能を実装します。詳細については、「データクレンジング」をご参照ください。

        4. Sink (ターゲット) ステップで、サービスタイプ パラメーターを [簡易 Log Service] に設定し、画面の指示に従って他のパラメーターを設定します。次に、[保存] をクリックします。次の表にパラメーターを示します。

        表 1. 簡易 Log Service

        パラメーター

        説明

        例

        ログプロジェクト

        作成した簡易 Log Service プロジェクト。

        guide-sls-sink-project

        ログストア

        作成した簡易 Log Service ログストア。

        guide-sls-sink-logstore

        ログトピック

        簡易 Log Service でトピックを生成するために使用されるメソッド。

        • 空

        • 固定値

        • 部分データ

        • テンプレート

        空

        ログ内容

        • デフォルトフォーマット (JSON)

        • カスタムフォーマット (キー/値)

        デフォルトフォーマット (JSON)

        ロール名

        EventBridge が簡易 Log Service にデータを書き込むためにアシュームできるロール。ロールがない場合は、画面の指示に従ってロールを作成できます。

        sls_eb

    4. タスクリスト ページに戻り、作成した OSS シンクコネクタを探し、操作する 列の 有効化する をクリックします。

    5. ヒント メッセージで、OK をクリックします。

      コネクタが有効になるまで 30 ～ 60 秒かかります。タスクリスト ページの Status 列で進行状況を確認できます。

    ステップ 3：簡易 Log Service シンクコネクタをテストする

    1. [タスク] ページで、作成した簡易 Log Service シンクコネクタを探し、[イベントソース] 列のソース トピックをクリックします。

    2. トピック詳細ページで、[メッセージの送信] をクリックします。

    3. [メッセージの送受信を開始] パネルで、次の図に基づいてパラメーターを設定し、[OK] をクリックします。

      发送消息

    4. [タスク] ページで、作成した簡易 Log Service シンクコネクタを探し、[イベントターゲット] 列のデスティネーション プロジェクトをクリックします。

    5. ログストアページで、ログコンテンツを表示します。

      日志