Salesforce(APEX) からAmazon SQSへのメッセージ送信

Owned by Site_admin_1
9月 21, 2023

Salesforce(Apex)で、AWSのAPIを利用してAmazon SQSへメッセージを挿入するサンプルになります。
SkyOnDemandのSQSアダプタでメッセージ受信する連携スクリプトを構築することで、Salesforce（Apex）からAmazon SQSを介したSkyOnDemandの連携処理を行うことが可能となります。

 

送信処理の呼出し

    • メッセージ挿入を行いたいアクションで、下記のコードを記載します。

    • 1行めの”message"に、送信したいメッセージを設定します。
       

String message = 'YOUR-message';
AwsSqsClient sqsclient = new AwsSqsClient();
sqsclient.SendMessage(message);

送信処理（AwsSqsClient)

上記の送信処理の呼出しにより、実際の送信処理を行うApexコードサンプルになります。

 [AwsSqsClient]  

    • 23 - 26行目ので、AWSへのアクセスに必要なアカウント情報を設定します。
      対象のアカウント情報を、設定してください。 

[createHttpRequest]  

    • Httpリクエストに必要な情報を生成します。

[getSignature]

    • アクセスに必要な認証情報(AWS 署名バージョン4（Signature Version 4 Signing Process）)を生成します。 
GETメソッド版 
public without sharing class AwsSqsClient {

	private static final String HASH_ALGORITHM = 'SHA-256';
	private static final String MAC_ALGORITHM = 'HmacSHA256';
	private static final String SIGNATURE_VERSION = 'AWS4';
	private static final String SIGNATURE_ALGORITHM = 'AWS4-HMAC-SHA256';
	private final String accessKeyId;
	private final String secretAccessKey;
	private final String serviceName;
	private final String region;
	private final String host;
	private final String apiVersion;
	private final String signedHeaders;
	private final String method;
	private final String quePath; //メッセージを挿入するキューのパス　[アカウント名]/que名
	private String now;
	private String today;
	private String xAmzTarget;
	private String queryStr;
	private String queryBody;

	public AwsSqsClient() {
		this.accessKeyId = 'YOUR-AccessKeyId';
		this.secretAccessKey = 'YOUR-SecretAccessKey';
		this.region = 'YOUR-AWS-region';   //ex.: ap-northeast-1
		this.quePath = 'YOUR que-path'; //ex.:your-account name/target-que name'
		this.serviceName = 'sqs';
		this.apiVersion = '2012-11-05';
		this.method = 'POST';
		this.host = this.serviceName.toLowerCase() + '.' + this.region + '.amazonaws.com';
		this.signedHeaders = 'content-type;host;x-amz-date';
	}

	public HttpResponse sendMessage(String message) {
		HTTPRequest req = createHttpRequest(message,'SendMessage');
		Http http = new Http();
		return http.send(req);
	}

	private HTTPRequest createHttpRequest(String message, String apiName) {
		Datetime dt = Datetime.now();
		this.today = dt.formatGmt('yyyyMMdd');
		this.now = this.today + 'T' + dt.formatGmt('HHmmss') + 'Z';
		this.queryStr = 'AWSAccessKeyId=' + this.accessKeyId +
                                    '&Action=' + apiName +
                                    '&MessageBody=' + message +
                                    '&SignatureMethod=' + MAC_ALGORITHM +
                                    '&SignatureVersion=4' +
                                    '&Version=' + this.apiVersion;
		// Sign
		String sign = getSignature();
		// Credential
		String credential = this.accessKeyId + '/' + this.today + '/' + this.region + '/' + this.serviceName.toLowerCase() + '/aws4_request';
		// Create Request
		HttpRequest req = new HttpRequest();
		// Set Header
		req.setHeader('Authorization',V4.SIGNATURE_ALGORITHM + ' Credential=' + credential + ',SignedHeaders=' + this.signedHeaders + ',Signature=' + sign);
		req.setHeader('Host', this.host);
		req.setHeader('x-amz-date', this.now);
		req.setHeader('Content-Type', 'application/x-www-form-urlencoded');
		// Set method
		req.setMethod(this.method);
		// Set End-point
		req.setEndpoint('https://' + this.serviceName.toLowerCase() + '.' + this.region + '.amazonaws.com' + this.quePath + '?' + this.queryStr);
		
		return req;
	}

	private String getSignature() {
		// Task 1: Create a Canonical Request For Signature Version 4
		String cs = this.method + '\n'
        	   cs += this.quePath + '\n';
               cs += this.queryStr + '\n';
          	   cs += 'content-type:' + 'application/x-www-form-urlencoded' + '\n'; 
          	   cs += 'host:' + this.host + '\n';  
          	   cs += 'x-amz-date:' + this.now + '\n\n';
          	   cs += this.signedHeaders + '\n';
          	   cs += EncodingUtil.convertToHex(Crypto.generateDigest(HASH_ALGORITHM, Blob.valueOf(this.queryBody)));
        // Task 2: Create a String to Sign for Signature Version 4
        String sts = SIGNATURE_ALGORITHM + '\n';
               sts += this.now + '\n';
               sts += this.today + '/' + this.region + '/' + this.serviceName.toLowerCase() + '/aws4_request\n';
        // Task 3: Calculate the AWS Signature Version 4
        Blob keyDate = Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf(this.today), Blob.valueof(SIGNATURE_VERSION + this.secretAccessKey));
        Blob keyRegion = Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf(this.region), keyDate);
        Blob keyService = Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf(this.serviceName.toLowerCase()), keyRegion);
        Blob keyCredentials = Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf('aws4_request'), keyService);
        // Task 1 + Task 2
        sts += EncodingUtil.convertToHex(Crypto.generateDigest(HASH_ALGORITHM, Blob.valueOf(cs)));
        // Task 2 + Task 3
        return EncodingUtil.convertToHex(Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf(sts), keyCredentials));
    }
}
POSTメソッド版 
public without sharing class AwsSqsClient {
	
	private static final String HASH_ALGORITHM = 'SHA-256';
	private static final String MAC_ALGORITHM = 'HmacSHA256';
	private static final String SIGNATURE_VERSION = 'AWS4';
	private static final String SIGNATURE_ALGORITHM = 'AWS4-HMAC-SHA256';
	private final String accessKeyId;
	private final String secretAccessKey;
	private final String serviceName;
	private final String region;
	private final String host;
	private final String apiVersion;
	private final String signedHeaders;
	private final String method;
	private final String quePath; //メッセージを挿入するキューのパス　[アカウント名]/que名
	private String now;
	private String today;
	private String xAmzTarget;
	private String queryStr;
	private String queryBody;

	public AwsSqsClient() {
		this.accessKeyId = 'YOUR-AccessKeyId';
		this.secretAccessKey = 'YOUR-SecretAccessKey';
		this.region = 'YOUR-AWS-region';   //ex.: ap-northeast-1
		this.quePath = 'YOUR que-path'; // ex. : 152270972222/test_scriptrunner_que'
		this.serviceName = 'sqs';
		this.apiVersion = '2012-11-05';
		this.method = 'POST';
		this.host = this.serviceName.toLowerCase() + '.' + this.region + '.amazonaws.com';
		this.signedHeaders = 'content-type;host;x-amz-date';
	}

	public HttpResponse sendMessage(String message) {
		HTTPRequest req = createHttpRequest(message,'SendMessage');
		Http http = new Http();
		return http.send(req);
	}

	private HTTPRequest createHttpRequest(String message, String apiName) {
		Datetime dt = Datetime.now();
		this.today = dt.formatGmt('yyyyMMdd');
		this.now = this.today + 'T' + dt.formatGmt('HHmmss') + 'Z';
		this.queryBody = 'AWSAccessKeyId=' + this.accessKeyId +
                         '&Action=' + apiName +
                         '&MessageBody=' + message +
                         '&SignatureMethod=' + MAC_ALGORITHM +
                         '&SignatureVersion=4' +
                         '&Version=' + this.apiVersion;
		// Sign
		String sign = getSignature();
		// Credential
		String credential = this.accessKeyId + '/' + this.today + '/' + this.region + '/' + this.serviceName.toLowerCase() + '/aws4_request';
		// Create Request
		HttpRequest req = new HttpRequest();
		// Set Header
		req.setHeader('Authorization',V4.SIGNATURE_ALGORITHM + ' Credential=' + credential + ',SignedHeaders=' + this.signedHeaders + ',Signature=' + sign);
		req.setHeader('Host', this.host);
		req.setHeader('x-amz-date', this.now);
		req.setHeader('Content-Type', 'application/x-www-form-urlencoded');
		// Set method
		req.setMethod(this.method);
		// Set End-point
		req.setEndpoint('https://' + this.serviceName.toLowerCase() + '.' + this.region + '.amazonaws.com' + this.quePath);
		//Set Body
		req.setBody(this.queryBody);

		return req;
	}
	private String getSignature() {
		// Task 1: Create a Canonical Request For Signature Version 4
		String cs = this.method + '\n'
        	   cs += this.quePath + '\n';
               cs += this.queryStr + '\n';
          	   cs += 'content-type:' + 'application/x-www-form-urlencoded' + '\n'; 
          	   cs += 'host:' + this.host + '\n';  
          	   cs += 'x-amz-date:' + this.now + '\n\n';
          	   cs += this.signedHeaders + '\n';
          	   cs += EncodingUtil.convertToHex(Crypto.generateDigest(HASH_ALGORITHM, Blob.valueOf(this.queryBody)));
        // Task 2: Create a String to Sign for Signature Version 4
        String sts = SIGNATURE_ALGORITHM + '\n';
               sts += this.now + '\n';
               sts += this.today + '/' + this.region + '/' + this.serviceName.toLowerCase() + '/aws4_request\n';
        // Task 3: Calculate the AWS Signature Version 4
        Blob keyDate = Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf(this.today), Blob.valueof(SIGNATURE_VERSION + this.secretAccessKey));
        Blob keyRegion = Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf(this.region), keyDate);
        Blob keyService = Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf(this.serviceName.toLowerCase()), keyRegion);
        Blob keyCredentials = Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf('aws4_request'), keyService);
        // Task 1 + Task 2
        sts += EncodingUtil.convertToHex(Crypto.generateDigest(HASH_ALGORITHM, Blob.valueOf(cs)));
        // Task 2 + Task 3
        return EncodingUtil.convertToHex(Crypto.generateMac(MAC_ALGORITHM, Blob.valueOf(sts), keyCredentials));
    }
}