このユースケースでは、APIまたはアプリケーションによってメッセージがAWS SQSキューに送信されたときに、Shopifyで顧客がどのように作成されるかについて説明します。 SQSポーリングは、メッセージ・データをマップし、Shopify APIを起動して顧客を作成する統合ワークフローをトリガーします。
このユースケースでは、次のアダプタとその操作が使用されます:
- Amazon Simple Queue Service (SQS)アダプタ(トリガー接続として構成): SQSキューをポーリングして統合をトリガーします。
- Shopifyアダプタ(呼出し接続として構成): Shopify APIを起動して新しい顧客を作成します。
この実装パターンでは、ステップの概要を示します。
- Amazon Simple Queue Service (SQS)アダプタ・トリガー接続を作成し、Shopifyアダプタ呼出し接続を作成します。
- アプリケーション統合を作成します。
- Amazon Simple Queue Service (SQS)アダプタをトリガー接続として統合キャンバスにドラッグします。
- Amazon Simple Queue Service (SQS)アダプタ・エンドポイントを次のように構成します:
- 「基本情報」ページで、意味のある名前を指定します。
- 「構成」ページで、メッセージを受信するキューを選択します。
- メッセージ・フォーマットを選択し、メッセージ・サンプルを指定します。
- 配信されないJSONおよびXMLメッセージを取得するには、「配信不能キューの選択」を選択します。
- 配信不能キューをFIFO配信不能キューとして選択した場合は、グループIDを入力します。
- 受信するメッセージの最大数(最大10)を入力します。
ノート:
メッセージ数はJSON形式にのみ指定できます。 AVROの場合、キューは一度に1つのメッセージのみを受信できます。
- 必要に応じて、メッセージ・エンコーディングを有効にするか、メッセージ属性名を構成するか、メッセージ・システム属性名を構成します。
- サマリー・ページで、選択内容を確認して確認します。
- Shopifyアダプタを呼出し接続として統合キャンバスにドラッグします。
- Shopifyアダプタ・エンドポイントを次のように構成します。
- 「基本情報」ページで、わかりやすい名前を指定します。
- 「アクション」ページで、アクションとして「作成」を選択します。
- 「操作」ページで、モジュールとして「顧客」を選択し、操作として「顧客の作成」を選択します。
- サマリー・ページで、選択内容を確認して確認します。
- マッパーで、メッセージ本文をShopify顧客フィールドにマップします。
- 完了したら、統合をアクティブ化します。
完了した統合は次のようになります。

アクティブ化すると、メッセージが(APIまたはアプリケーションを介して)SQSキューに送信されるたびに、統合がトリガーされます。 ワークフローによってメッセージが処理され、Shopifyで新規顧客が作成されます。