すべてのプロダクト
Search

このプロダクト

    CloudFlow:EventBridgeイベントスケジューリング

    ドキュメントセンター

    CloudFlow:EventBridgeイベントスケジューリング

    最終更新日:Mar 31, 2025

    EventBridgeイベントスケジューリングには、クラウドサービスのイベントスケジューリングとカスタムイベントソースを持つイベントスケジューリングが含まれます。クラウドサービスのイベントスケジューリングは、エラスティックコンピューティング、ストレージサービス、データベース、コンテナ、ビッグデータ処理、オブザーバビリティサービス、ミドルウェアサービスの分野におけるほぼすべてのAlibaba Cloudサービスのイベントソースをサポートしています。カスタムイベントソースを持つイベントスケジューリングは、Simple Log Service、ApsaraMQ for Kafka、ApsaraMQ for RocketMQ、およびApsaraMQ for RabbitMQのイベントソースをサポートしています。このトピックでは、EventBridgeイベントスケジューリングを作成する方法について説明します。また、ワークフロースケジューリングの高度な機能についても説明します。

    EventBridgeイベントスケジューリングの作成

    クラウドサービスのイベントスケジューリング

    クラウドサービスのイベントスケジューリングは、Alibaba Cloudサービスイベントを使用してワークフロースケジューリングを実装します。イベントには、CloudMonitorイベント、監査イベント、Elastic Compute Service（ECS）イベント、Alibaba Cloud IoTイベント、および特定のAlibaba CloudサービスのO&Mイベントが含まれます。次の例では、ECSを使用して、CloudFlowコンソールでAlibaba Cloudサービスのイベントスケジューリングを作成する方法について説明します。

    機能説明

    CloudFlowコンソールでEventBridgeワークフロースケジューリングの作成リクエストを送信すると、ワークフロースケジューリングの構成に基づいて、Alibaba Cloudサービスの default という名前のイベントバスに rule-created-by-fnf-<ランダムな文字列> という名前のイベントルールが自動的に作成されます。EventBridgeワークフロースケジューリングが作成されると、CloudFlowコンソールのワークフロー詳細ページでワークフロースケジューリング情報を表示できます。また、EventBridgeコンソールで自動的に作成されたイベントルールに関する情報を表示することもできます。イベントソースで指定されたタイプのイベントがイベントバスに配信されると、ワークフロースケジューリングに関連付けられたワークフローが1回実行されるようにスケジュールされます。

    注意事項

    クラウドサービス用に設計された default イベントバスには、最大10個のイベントルールを作成できます。

    前提条件

    クラウドサービスのイベントスケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングタイプ] パラメーターを Elastic Compute Service (ECS) に設定し、パラメーターを構成して、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロースケジューリングのカスタム名を入力します。

      ecs-schedule

      イベントタイプ

      [カスタム] または [すべて] を選択します。 [カスタム] を選択した場合は、1つ以上のECSのイベントタイプを選択できます。

      [カスタム] および [ecs:disk:converttopostpaidcompleted]

      イベントモードコンテンツ

      [イベントタイプ] パラメーターを構成すると、イベントモードコンテンツが自動的に入力されます。コンテンツを変更することはできません。イベントモードの詳細については、イベントパターンをご参照ください。

      {
 // イベントソース
 "source": [
 "acs.ecs"
 ],
 // イベントタイプ
 "type": [
 "ecs:Disk:ConvertToPostpaidCompleted"
 ]
}

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    HTTPワークフロースケジューリング

    イベントソースとして機能するHTTPリクエストが CloudFlow と EventBridge を使用して統合されると、HTTPワークフロースケジューリングは関連付けられたワークフローの実行をトリガーできます。このセクションでは、CloudFlowコンソールでHTTPワークフロースケジューリングを作成する方法について説明します。

    注意事項

    既存のカスタムバスとイベントルールの数が上限に達すると、イベントモードのHTTPワークフロースケジューリングを作成できなくなります。単一のAlibaba Cloudアカウントと単一のリージョンでワークフロースケジューリングを作成するために使用されるリソース数の制限については、制限をご参照ください。

    前提条件

    HTTPワークフロースケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングの種類] パラメーターを [HTTP/HTTPS リクエストによってトリガーされる] に設定し、パラメーターを構成して、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロースケジューリングのカスタム名を入力します。

      https-schedule

      リクエストタイプ

      [HTTPS]、[HTTP]、または [HTTP&HTTPS] を選択します。

      HTTP

      リクエストメソッド

      サポートされているHTTPリクエストメソッドを1つ以上選択します。有効な値：

      • GET

      • POST

      • PUT

      • DELETE

      • HEAD

      • PATCH

      GET

      セキュリティ設定

      セキュリティ設定タイプを選択します。有効な値：

      • N/A：セキュリティ設定は有効になっていません。受信したすべてのURLリクエストがワークフローの実行をトリガーできます。

      • CIDRブロック：リクエストが許可される1つ以上のIPアドレスまたはCIDRブロックを入力します。指定されたIPアドレスまたは指定されたCIDRブロック内のIPアドレスを使用するURLリクエストのみが、ワークフローの実行をトリガーできます。最大5つのIPアドレスまたはCIDRブロックを追加できます。

      • セキュアドメイン名：1つ以上のセキュアドメイン名を入力します。セキュアドメイン名を使用するURLリクエストのみが、ワークフローの実行をトリガーできます。最大5つのセキュアドメイン名を入力できます。

      CIDRブロック：10.45.12.0/24

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    Simple Message Queue (formerly MNS) ワークフロースケジューリング

    注意事項

    • イベントソースとして機能する Simple Message Queue (formerly MNS) キューは、ワークフロースケジューリングを作成するワークフローと同じリージョンに存在する必要があります。

    • 既存のイベントストリームの数が上限に達すると、イベントモードの Simple Message Queue (formerly MNS) スケジューリングを作成できなくなります。単一のAlibaba Cloudアカウントと単一のリージョンでワークフロースケジューリングを作成するために使用されるリソース数の制限については、制限をご参照ください。

    前提条件

    ワークフロースケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングタイプ] パラメーターを [メッセージサービス (MNS)] に設定し、パラメーターを構成して、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロースケジューリングのカスタム名を入力します。

      mns-schedule

      キュー名

      Simple Message Queue (formerly MNS) キューを選択します。

      MyQueue

      Base64デコード

      配信前に Simple Message Queue (formerly MNS) データをデコードする場合は、[base64デコードを有効にする] を選択します。

      [base64デコードを有効にする]

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    Kafkaワークフロースケジューリング

    注意事項

    • イベントソースとして機能するApsaraMQ for Kafkaインスタンスは、ワークフロースケジューリングを作成するワークフローと同じリージョンに存在する必要があります。

    • 既存のイベントストリームの数が上限に達すると、Kafkaワークフロースケジューリングを作成できなくなります。単一のAlibaba Cloudアカウントと単一のリージョンでワークフロースケジューリングを作成するために使用されるリソース数の制限については、制限をご参照ください。

    前提条件

    Kafkaワークフロースケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングタイプ] パラメーターを ApsaraMQ for Kafka に設定し、パラメーターを構成して、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロースケジューリングのカスタム名を入力します。

      kafka-schedule

      Kafkaインスタンス

      ApsaraMQ for Kafkaインスタンスを選択します。

      alikafka_pre-cn-i7m2t7t1****

      トピック

      ApsaraMQ for Kafkaインスタンスのトピックを選択します。

      topic1

      グループID

      ApsaraMQ for KafkaインスタンスのグループIDを選択します。

      重要

      ワークフロースケジューリングを作成するには、個別のグループIDを使用する必要があります。別のメッセージングサービスの既存のグループIDを使用しないでください。別のメッセージングサービスの既存のグループIDを使用すると、別のメッセージングサービスを使用してメッセージを送受信できない場合があります。

      GID_group1

      同時消費タスク

      同時コンシューマーの数を指定します。有効な値：1から<トピックのパーティション数>。

      2

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

      ApsaraMQ for KafkaがEventBridgeからメッセージのプルを開始するオフセットを選択します。有効な値：

      • [最も古いオフセット]：最も古いオフセットからメッセージをプルします。

      • [最新のオフセット]：最新のオフセットからメッセージをプルします。

      最新のオフセット

      ネットワーク設定

      メッセージをルーティングするネットワークのタイプを選択します。有効な値：

      • [デフォルトネットワーク]：ApsaraMQ for Kafkaインスタンスのデプロイ時に指定されたVPC IDとvSwitch IDを自動的に使用します。

      • [インターネット]：[virtual Private Cloud（vpc）]、[vswitch]、[セキュリティグループ] パラメーターを指定する必要があります。

      デフォルトネットワーク

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    RocketMQワークフロースケジューリング

    注意事項

    • イベントソースとして機能するApsaraMQ for RocketMQインスタンスは、ワークフロースケジューリングを作成するワークフローと同じリージョンに存在する必要があります。

    • 既存のイベントストリームの数が上限に達すると、イベントモードのRocketMQワークフロースケジューリングを作成できなくなります。単一のAlibaba Cloudアカウントと単一のリージョンでワークフロースケジューリングを作成するために使用されるリソース数の制限については、制限をご参照ください。

    前提条件

    RocketMQワークフロースケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングタイプ] パラメーターを ApsaraMQ for RocketMQ に設定し、パラメーターを構成してから、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロースケジューリングのカスタム名を入力します。

      rocketmq-schedule

      Apsaramq For Rocketmqインスタンス

      ApsaraMQ for RocketMQインスタンスを選択します。

      MQ_INST_164901546557****_BX7****

      トピック

      ApsaraMQ for RocketMQインスタンスのトピックを選択します。

      topic1

      タグ

      メッセージをフィルタリングするために使用されるタグを指定します。フィルターラベル文字列を含むメッセージを受信した場合にのみ、CloudFlowはワークフローの実行をトリガーします。

      tag

      グループID

      ApsaraMQ for RocketMQインスタンスのグループIDを選択します。[作成] を選択することをお勧めします。その後、システムは GID_FNF_TRIGGER_{uuid}_{timestamp} という名前のグループIDを自動的に作成します。

      重要

      ワークフロースケジューリングを作成するには、個別のグループIDを使用する必要があります。別のメッセージングサービスの既存のグループIDを使用しないでください。別のメッセージングサービスの既存のグループIDを使用すると、別のメッセージングサービスを使用してメッセージを送受信できない場合があります。

      GID_group1

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

      ApsaraMQ for RocketMQがEventBridgeからメッセージのプルを開始するオフセットを選択します。有効な値：

      • [最新のオフセット]：最新のオフセットからメッセージをプルします。

      • [最も古いオフセット]：最も古いオフセットからメッセージをプルします。

      • [タイムスタンプ]：指定されたタイムスタンプからメッセージをプルします。

      最新のオフセット

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    RabbitMQワークフロースケジューリング

    注意事項

    • イベントソースとして使用されるApsaraMQ for RabbitMQインスタンスは、ワークフロースケジューリングを作成するワークフローと同じリージョンに存在する必要があります。

    • 既存のイベントストリームの数が上限に達すると、イベントモードのRabbitMQワークフロースケジューリングを作成できなくなります。単一のAlibaba Cloudアカウントと単一のリージョンでワークフロースケジューリングを作成するために使用されるリソース数の制限については、制限をご参照ください。

    前提条件

    RabbitMQワークフロースケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングタイプ] パラメーターを ApsaraMQ for RabbitMQ に設定し、パラメーターを構成してから、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロー スケジューリングのカスタム名を入力します。

      rabbitmq-schedule

      Apsaramq For Rabbitmqインスタンス

      ApsaraMQ for RabbitMQ インスタンスを選択します。

      amqp-cn-i7m2l6m2****

      Vhost

      ApsaraMQ for RabbitMQ インスタンスで vhost を選択します。

      myhost-1

      キュー

      ApsaraMQ for RabbitMQ インスタンスのキューを選択します。

      myqueue-1

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    Simple Log Serviceワークフロースケジューリング

    Simple Log Serviceワークフロースケジューリングは、Simple Log ServiceをCloudFlowに接続します。新しいログが生成されると、ワークフローの実行がトリガーされ、ログが処理されます。このセクションでは、CloudFlowコンソールでSimple Log Serviceワークフロースケジューリングを作成する方法について説明します。

    注意事項

    • イベントソースとして使用されるSimple Log Serviceプロジェクトは、ワークフロースケジューリングを作成するワークフローと同じリージョンに存在する必要があります。

    • 既存のイベントストリームの数が上限に達すると、イベントモードのSimple Log Serviceワークフロースケジューリングを作成できなくなります。単一のAlibaba Cloudアカウントと単一のリージョンでワークフロースケジューリングを作成するために使用されるリソース数の制限については、制限をご参照ください。

    前提条件

    Simple Log Serviceワークフロースケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングの種類] パラメーターを [ログサービス] に設定し、パラメーターを構成してから、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロースケジューリングのカスタム名を入力します。

      sls-schedule

      プロジェクト

      既存のSimple Log Serviceプロジェクトを選択します。

      test-Project

      ログストア

      既存のSimple Log Serviceログストアを選択します。

      test-LogStore

      コンシューマーオフセットの開始

      CloudFlowがメッセージをプルするオフセット。有効な値：最も古いオフセット、最新のオフセット、タイムスタンプ。

      最新のオフセット

      ログサービロールの構成

      Simple Log Serviceロールを選択します。EventBridgeは、Simple Log Serviceログを読み取るためにロールを引き受けます。

      testRole

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    MQTTワークフロースケジューリング

    イベントソースとして機能する ApsaraMQ for MQTT インスタンスが CloudFlow と EventBridge を使用して統合されると、ApsaraMQ for MQTTワークフロースケジューリングは関連付けられたワークフローの実行をトリガーできます。その後、CloudFlow は、カスタム構成に基づいて ApsaraMQ for MQTT にパブリッシュされたメッセージを処理します。このセクションでは、CloudFlowコンソールでMQTTワークフロースケジューリングを作成する方法について説明します。

    注意事項

    • イベントソースとして使用されるApsaraMQ for MQTTインスタンスは、ワークフロースケジューリングを作成するワークフローと同じリージョンに存在する必要があります。

    • 既存のイベントストリームの数が上限に達すると、イベントモードのMQTTワークフロースケジューリングを作成できなくなります。単一のAlibaba Cloudアカウントと単一のリージョンでワークフロースケジューリングを作成するために使用されるリソース数の制限については、制限をご参照ください。

    前提条件

    MQTTワークフロースケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングタイプ] パラメーターを ApsaraMQ for MQTT に設定し、パラメーターを構成して、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロースケジューリングのカスタム名を入力します。

      mqtt-schedule

      Apsaramq For MQTTインスタンス

      ApsaraMQ for MQTTインスタンスを選択します。

      mqtt-xxx

      MQTTトピック

      ApsaraMQ for MQTTインスタンスのトピックを選択します。

      testTopic

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    DTSワークフロースケジューリング

    イベントソースとして機能する Data Transmission Service (DTS) インスタンスが CloudFlow と EventBridge を使用して統合されると、DTSワークフロースケジューリングは関連付けられたワークフローの実行をトリガーできます。このトピックでは、CloudFlowコンソールでDTSワークフロースケジューリングを作成する方法について説明します。

    注意事項

    • イベントソースとして使用されるDTS変更追跡タスクは、ワークフロースケジューリングを作成するワークフローと同じリージョンに存在する必要があります。

    • 既存のイベントストリームの数が上限に達すると、イベントモードのDTSワークフロースケジューリングを作成できなくなります。単一のAlibaba Cloudアカウントと単一のリージョンでワークフロースケジューリングを作成するために使用されるリソース数の制限については、制限をご参照ください。

    前提条件

    DTSワークフロースケジューリングを作成する

    1. CloudFlowコンソール にログオンします。トップナビゲーションバーで、リージョンを選択します。

    2. 左側のナビゲーションペインで、[ワークフロー] をクリックします。[ワークフロー] ページで、管理するワークフローをクリックします。

    3. ワークフローの詳細ページで、[ワークフロースケジューリング] タブをクリックし、[ワークフロースケジューリングの作成] をクリックします。

    4. [ワークフローのスケジューリングの作成] パネルで、[スケジューリングタイプ] パラメーターを [データ伝送サービス (DTS)] に設定し、パラメーターを構成して、[OK] をクリックします。次の表は、基本的なパラメーターについて説明しています。

      パラメーター

      説明

      例

      名前

      ワークフロースケジューリングのカスタム名を入力します。

      dts-schedule

      変更追跡タスク

      変更追跡タスクを選択します。

      dtsqntc2***

      コンシューマーグループ

      変更追跡タスクの消費に使用するコンシューマーグループを選択します。

      test

      アカウント

      コンシューマーグループの作成時に指定したアカウント名を入力します。

      test

      パスワード

      コンシューマーグループの作成時に指定したアカウントパスワードを入力します。

      *******

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

      最初のデータがプルされるタイムスタンプを指定します。コンシューマーオフセットは、DTSインスタンスのデータセット内である必要があります。

      2022-06-21 00:00:00

      プッシュ設定、再試行ポリシー、デッドレターキューパラメーターなどの高度なパラメーターについては、ワークフロースケジューリングの高度な機能をご参照ください。ワークフロースケジューリングを作成した後、画面の指示に従って、ワークフロー詳細ページの [ワークフロースケジューリング] タブで、ワークフロースケジューリングの表示、編集、削除、有効化、無効化を行うことができます。

    ワークフロースケジューリングの高度な機能

    プッシュフォーマット

    プッシュフォーマットは、Eventパラメーターの各データ要素のフォーマットを指定するために使用されます。

    • [cloudevents]：共通フォーマットでイベントデータを記述するための仕様。CloudEventsは、異なるサービスとプラットフォーム間でのイベントの宣言と送信を簡素化します。

    • [rawdata]：CloudEventsのデータフィールドの内容のみが配信されます。CloudEventsフォーマットの他のメタデータは配信されません。

    バッチプッシュ

    バッチプッシュを有効にした後、バッチプッシュメッセージの数とバッチプッシュ間隔を指定する必要があります。

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

    • バッチプッシュ間隔：関数が呼び出される間隔。システムはメッセージを集約し、指定された時間間隔で CloudFlow に送信します。有効な値：0～15。単位：秒。値0は、メッセージがリアルタイムで送信されることを示します。

    バッチプッシュの例：

    • 例1：

      バッチプッシュメッセージの数を10、各メッセージのサイズを1 KB、バッチプッシュ間隔を15秒に設定します。メッセージの数が10秒以内に10に達します。この場合、15秒待たずにメッセージがすぐに送信されます。

    • 例2：

      バッチプッシュメッセージの数を32、各メッセージのサイズを1 KB、バッチプッシュ間隔を15秒に設定します。メッセージの数が15秒以内に10に達します。この場合、32個のメッセージが集約されるのを待たずにメッセージがすぐに送信されます。

    • 例3：

      バッチプッシュメッセージの数を20、各メッセージのサイズを2 KB、バッチプッシュ間隔を15秒に設定します。メッセージの数が10秒以内に40に達します。メッセージの合計サイズは80 KB（40×2 KB）で、ワークフローの入力サイズ制限64 KBに達します。この場合、メッセージはすぐに送信されます。最初の32個のメッセージは最初のバッチで CloudFlow にプッシュされ、残りの8個のメッセージは2番目のバッチで CloudFlow にプッシュされます。

    再試行ポリシー

    メッセージのプッシュに失敗した場合、構成した再試行ポリシーに基づいてプッシュを再試行できます。使用可能な再試行ポリシーを以下に示します。

    • [バックオフ再試行]：システムはリクエストを最大3回再試行します。連続する2回の再試行の間隔はランダムで、10～20秒です。

    • [指数関数的減衰再試行]：デフォルトの再試行ポリシー。システムはリクエストを最大176回再試行します。連続する2回の再試行の間隔は指数関数的に増加し、最大512秒になります。再試行は24時間以内に行われます。再試行間隔は1秒、2秒、4秒、8秒、16秒、32秒、64秒、128秒、256秒、512秒です。512秒の間隔は167回使用されます。

    フォールトトレランスポリシー

    フォールトトレランスポリシーは、エラーが発生した場合に許容するかどうかを指定します。

    • [フォールトトレランスを許可]

      システムは、再試行後に実行に失敗したリクエストをスキップし、次のリクエストに進みます。

    • [フォールトトレランスを禁止]

      再試行後にリクエストの実行に失敗すると、消費がブロックされます。

    デッドレターキュー

    [フォールトトレランスを許可] が有効になっている場合にのみ、デッドレターキューを構成できます。

    • デッドレターキュー機能を有効にすると、処理されなかったメッセージ、または最大再試行回数を超えたメッセージは、宛先サービスに配信されます。CloudFlowでは、以下のサービスを宛先サービスとして使用できます。Simple Message Queue (formerly MNS)、ApsaraMQ for RocketMQ、ApsaraMQ for Kafka、EventBridge。ビジネス要件に基づいてキュータイプを選択できます。

    • デッドレターキュー機能を有効にしない場合、最大再試行回数を超えたメッセージは破棄されます。