Amazon API Gateway を Salesforce からコールアウトする

Amazon API Gateway を使って作成した Rest API を Salesforce からコールアウトしてみたいと思います。

Salesforce からのコールアウトのイメージを掴むには下記のエントリーもご参照ください。

[Salesforce] リード作成時にコールアウトを使ってJiraにチケットを作る

Amazon API Gateway で Rest APIを作る

API GatewayとStep Functionsを組み合わせた非同期APIが最強だった話

の記事のサンプルをベースに使わせていただきました。

サンプルではoutputが固定なので、少し改修してinputの値を表示するようにしました。

diff --git a/app.py b/app.py
index 9f20415..ac0c7fb 100644
--- a/app.py
+++ b/app.py
@@ -12,4 +12,4 @@ def lambda_handler(event, context):
     seconds = int(os.environ.get("TIMER"))
     sleep(seconds)

-    return {"message": "らーめんが ゆであがりました はやく たべないと のびて しまいます"}
+    return {"message": f"{event['lead-name']}さんに用意した{event['aji']}らーめんが ゆであがりました はやく たべないと のびて しまいます"}

実行は次の通りです。

デプロイして¹、

$ sls deploy --stage default

エンドポイントを設定して、

# Set Api Endpoint
$ StartExecution=https://XXXXXXXXXX.execute-api.ap-northeast-1.amazonaws.com/<ステージ名>/ramen/start-execution
$ DescribeExecution=https://XXXXXXXXXX.execute-api.ap-northeast-1.amazonaws.com/<ステージ名>/ramen/describe-execution

実行する。

# StartExecution
$ executionArn=$(curl -X POST -d '{"lead-name": "進地", "aji": "みそ"}' $StartExecution | jq -r '.executionArn')

# DescribeExecution
$ curl -X POST -d '{"executionArn": "'$executionArn'"}' $DescribeExecution | jq

結果は、DescribeExecutionがStartExecutionの実行直後の実行だと、

% curl -X POST -d '{"executionArn": "'$executionArn'"}' $DescribeExecution | jq
  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current
                                 Dload  Upload   Total   Spent    Left  Speed
100   208  100    77  100   131    350    595 --:--:-- --:--:-- --:--:--   945
{
  "input": {
    "lead-name": "進地",
    "aji": "みそ"
  },
  "status": "RUNNING"
}

しばらく待ってから再実行すると、

$ curl -X POST -d '{"executionArn": "'$executionArn'"}' $DescribeExecution | jq
  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current
                                 Dload  Upload   Total   Spent    Left  Speed
100   488  100   357  100   131    642    235 --:--:-- --:--:-- --:--:--   877
{
  "input": {
    "lead-name": "進地",
    "aji": "みそ"
  },
  "output": {
    "message": "進地さんに用意したみそらーめんが ゆであがりました はやく たべないと のびて しまいます"
  },
  "status": "SUCCEEDED"
}

となります。

Salesforce から Amazon API Gateway で作った Rest API をコールアウトする

それでは、先に作成したAPIをSalesforceからコールアウトしてみます。

指定ログイン情報の作成

まず、Amazon API GatewayをApexからコールアウトできるように、指定ログイン情報を作成します。

指定ログイン情報に設定する各値は次の通りです。

AWSに対して接続する場合は認証プロトコルに「AWS 署名バージョン 4」が用意されていますので、認証プロバイダを自前で設定する必要がなくて楽ちんです。

コールアウトの実装

それでは、SalesforceでAmazon API Gateway をコールアウトする処理を実装します。

public with sharing class APIGatewayCalloutAsync implements Queueable,Database.AllowsCallouts {
    private final String body;
    private final Integer period;

    public APIGatewayCalloutAsync(String body, Integer period) {
        this.body = body;
        this.period = period;
    }

    public void execute(QueueableContext context) {
        Http http = new Http();
        HttpRequest req = new HttpRequest();
        req.setEndpoint('callout:AWS_APIGW/default/ramen/describe-execution');
        req.setMethod('POST');
        req.setHeader('Content-Type', 'application/json');
        req.setHeader('Accept', 'application/json');
        req.setBody(this.body);
        HttpResponse res = http.send(req);
        CalloutResponse cres = (CalloutResponse)JSON.deserializeStrict(res.getBody(), CalloutResponse.class);
        if ( cres.status != 'SUCCEEDED' ) {
            Long startTime = DateTime.now().getTime();
            Long finishTime = DateTime.now().getTime();
            while ((finishTime - startTime) < (this.period * 1000)) {
                //sleep for this.period sec
                finishTime = DateTime.now().getTime();
            }
            System.enqueueJob(this);
        } else {
            System.debug(cres.output.get('message'));
        }
    }

    class CalloutResponse {
        Map<String,String> input;
        Map<String,String> output;
        String status;
    }
}

APIGatewayCalloutAsync は非同期にAWS_APIGW/default/ramen/describe-executionへのコールアウトを繰り返すQueueableを実装したクラスです。コンストラクタの第二引数で与えた秒数間隔をあけて第一引数で与えたJSONをパラメータに使ってコールアウトします。

コールアウトから{"status": "SUCCEEDED"}が返ってくるまで繰り返し、返ってきたら{"output": {"message": "メッセージ"}}をデバッグ出力して終了します。

呼び出し側は、例えば開発者コンソールの[Debug] > [Open Execute Anonymous Window] にて次のコードを実行します。

HttpRequest req = new HttpRequest();
req.setEndpoint('callout:AWS_APIGW/default/ramen/start-execution');
req.setMethod('POST');
req.setHeader('Content-Type', 'application/json');
req.setHeader('Accept', 'application/json');
req.setBody('{"lead-name": "進地", "aji": "みそ"}');

Http http = new Http();
HttpResponse res = http.send(req);

ExecutionArn arn = (ExecutionArn)JSON.deserializeStrict(res.getBody(), ExecutionArn.class);
System.enqueueJob(new APIGatewayCalloutAsync('{"executionArn": "' + arn.executionArn + '"}', 10));

class ExecutionArn {
    String executionArn;
    String startDate;
}

AWS_APIGW/default/ramen/start-executionを呼び出してExecutionArnを取得し、取得したExecutionArnと繰り返しの間隔に10秒を指定してAPIGatewayCalloutAsyncオブジェクトをキューに追加しています。キューは10秒間隔でAPIGatewayCalloutAsync.execute()を実行し、先述の通りにoutputが返ってきたら終了します。

このサンプルの場合、最終結果として、進地さんに用意したみそらーめんが ゆであがりました はやく たべないと のびて しまいますという文章がデバッグ出力されれば成功です。

まとめ

Amazon API Gateway で作成した Rest API エンドポイントに対して、Salesforceからコールアウトする方法について書きました。 コールアウトでJiraにチケットを作る場合と比べても圧倒的に設定がシンプルで楽であることがおわかりいただけたかと思います。

また、 Amazon API Gateway と Step Functions で構成された非同期APIの実行処理に対して、処理完了したか判断してレスポンスを受け取るためのAPI（AWS_APIGW/default/ramen/describe-execution）を非同期で繰り返し実行する方法としてApexのQueueableインターフェースを実装する例を書いてみました。

AWS と Salesforce のインテグレーションの一形式として活用を検討してみてください。

参考資料

• API Gateway を使用して Step Functions API を作成する - AWS Step Functions
• Stepで覚えるStepFunctions基本のキ | DevelopersIO
• API GatewayとStep Functionsを組み合わせた非同期APIが最強だった話 - Qiita
• Serverless Frameworkの使い方まとめ | Serverless Operations
• もう一つの非同期、Queueable | エスパーラボ