HTTPタスクの作成

必要なパラメーターを設定します。詳細については、 HTTPタスクのPlanビュー を参照してください。

リクエストのヘッダー値とリクエスト本文で、プランのメタデータ情報を指定できます。詳細については、 Planメタデータの参照 を参照してください。

接続をテストするには、[ テスト ]をクリックします。成功メッセージが表示されます。

タスクを追加するには、[ 保存 ]をクリックします。

必要に応じて、メッセージを受信するSlackチャンネルを作成します。

アプリを作成します。

アプリの受信HTTPメッセージを有効にします。

受信メッセージを受け付けるチャンネルを指定します。

cURLステートメントから受信HTTPリクエストのURLをコピーします。

[ テスト ]をクリックして、このタスクが機能することを確認します。

ジョブを実行し、Slackチャンネルでメッセージを確認します。

プランを定義します。

フロータスク: フローを実行して、Lambda関数に必要な出力を生成します。

HTTPタスク: rowCountメタデータ変数への参照を本文に含むHTTPリクエストを生成します。リクエスト本文:

{
 "rowCount": "{{$flow_7p['My Flow Name'].output['My output name'].rowCount}}"
}

AWS Lambda関数: 以下はLambdaの擬似コードです。

import json
def lambda_handler(event, context):
  httpTaskBody = json.loads(event["body"])
  rowCount = httpTaskBody["rowCount"]

  return {
    'statusCode': 200,
    'body': json.dumps(rowCount)
  }

Google Cloud Functions: 以下はGoogle Cloud Functionsの擬似コードです。

def get_row_count(request):
  request_json = request.get_json()
  if request_json and 'rowCount' in request_json:
        rowCount = request_json['rowCount']
    return rowCount
  return 'No rowCount attribute provided'

区切り文字に「,」を使用して値を分割します。

各部分を「=」文字を使用して分割します。

タイムスタンプと署名の値を抽出します。上記の例では次のようになります。

1. タイムスタンプ: 1568818215724

2. 署名: 55fa71b2e391cd3ccba8413fb51ad16984a38edb3cccfe81f381c4b8197ee07a

タイムスタンプ、ドット文字「 . 」、 リクエストの本文(POST/PUT/PATCHメソッド)またはURL (GET/DELETEメソッド)を連結します。

上記の例が POST リクエストの署名で、リクエスト本文が「 test 」であるとします。連結された値は次のようになります。

1568818215724.test

これで、受信アプリケーションでHMAC認証コードを計算できます。次のJavaScriptの例では、シークレットキーの値は mySecret です。

const crypto = require('crypto');

const message = '1568818215724.test'; // as defined above

const hmac = crypto.createHmac('sha256', 'mySecret');
hmac.update(message)
const expectedSignature = hmac.digest('hex');