EventBridge:カスタムイベントバスにおけるイベントの分析

ルールマッピング

1. イベントバス ページで、管理対象のカスタムイベントバスをクリックします。左側のナビゲーションウィンドウで、イベントルール をクリックし、ルールの作成 をクリックします。

2. ルールの作成 パネルで、以下の手順を完了します：

   1. 基本情報の設定 ステップで、名前 および 説明 パラメーターを設定し、次のステップ をクリックします。

   2. イベントパターンの設定 ステップで、クエリ対象のカスタムイベントソースを指定し、次のステップ をクリックします。

   3. ターゲットの設定 ステップで、サービスタイプ を イベント分析 に、マッピング方法 を ルールマッピング に設定します。また、先の手順で作成したスキーマと同じ グループ名、スキーマ ID、および スキーマバージョン を選択します。

3. 作成 をクリックします。

プッシュマッピング

1. SDK コードに、先の手順で取得した dataschema パラメーターおよびスキーマ URI を追加し、イベントをプッシュします。以下の Java の例では、一連の処理の流れを示しています。

      import com.aliyun.eventbridge.EventBridge;
      import com.aliyun.eventbridge.EventBridgeClient;
      import com.aliyun.eventbridge.models.CloudEvent;
      import com.aliyun.eventbridge.models.Config;
      import com.aliyun.eventbridge.models.PutEventsResponse;
      import com.aliyun.eventbridge.util.EventBuilder;
      import com.google.gson.Gson;
   
      import java.net.URI;
      import java.util.ArrayList;
      import java.util.Date;
      import java.util.List;
   
      public class PutEventsSample {
   
          private EventBridge eventBridgeClient;
   
          public PutEventsSample() {
              Config authConfig = new Config();
              // 環境変数から AccessKey ID を取得します。
              authConfig.accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
              // 環境変数から AccessKey Secret を取得します。
              authConfig.accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
              // エンドポイントを指定します。リージョンおよびエンドポイントの詳細については、リージョンとエンドポイントをご参照ください。
              authConfig.endpoint = "<your-endpoint>";
              eventBridgeClient = new EventBridgeClient(authConfig);
          }
   
          public void putEventsSample() {
              List<CloudEvent> cloudEventList = new ArrayList<>();
              CloudEvent cloudEvent = EventBuilder.builder()
                  .withId("a5074581-7e74-4e4c-868f-47e7afdf****")
                  .withSource(URI.create("acs.oss"))
                  .withType("oss:ObjectCreated:PostObject")
                  .withSubject("acs:oss:cn-hangzhou:{yourAccountId}:xls-papk/game_apk/123.jpg")
                  .withTime(new Date())
                  .withJsonStringData("{ \"E-Mail\": \"${email}\" }")
                  .withAliyunEventBus("demo-bus")
                  .build();
              // 「カスタムスキーマの作成」手順で取得したスキーマ URI を設定します。
              cloudEvent.setDataschema("<schema-uri>");
              cloudEventList.add(cloudEvent);
              PutEventsResponse putEventsResponse = eventBridgeClient.putEvents(cloudEventList);
              System.out.println(new Gson().toJson(putEventsResponse));
          }
   
          public static void main(String[] args) {
              PutEventsSample sample = new PutEventsSample();
              try {
                  sample.putEventsSample();
              } catch (Throwable e) {
                  e.printStackTrace();
              }
          }
      }

   以下のプレースホルダーを実際の値に置き換えてください。

   プレースホルダー	説明	例
   <your-endpoint>	ご利用のリージョン向けの EventBridge エンドポイント	-
   <schema-uri>	先の手順で取得したスキーマ URI	-

2. イベントバス ページで、管理対象のカスタムイベントバスをクリックします。左側のナビゲーションウィンドウで、イベントルール をクリックし、ルールの作成 をクリックします。

3. ルールの作成 パネルで、以下の手順を完了します：

   1. 基本情報の設定 ステップで、名前 および 説明 パラメーターを設定し、次のステップ をクリックします。

   2. イベントパターンの設定 ステップで、クエリ対象のカスタムイベントソースを指定し、次のステップ をクリックします。

   3. ターゲットの設定 ステップで、サービスタイプ を イベント分析 に、マッピング方法 を プッシュマッピング に設定します。

4. 作成 をクリックします。

必須パラメーター

オプションパラメーター

キーと値の一致演算子