Simple Log Service:STS を使用して Simple Log Service リソースへのクロスアカウントアクセスを有効にする

package com.aliyun.openservices.log.sample;

import java.util.Date;
import java.util.Vector;

import com.aliyun.openservices.log.Client;
import com.aliyun.openservices.log.common.LogItem;
import com.aliyun.openservices.log.exception.LogException;
import com.aliyun.openservices.log.request.PutLogsRequest;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.http.MethodType;
import com.aliyuncs.http.ProtocolType;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import com.aliyuncs.sts.model.v20150401.AssumeRoleRequest;
import com.aliyuncs.sts.model.v20150401.AssumeRoleResponse;

public class StsSample {
	  // 現在、sts は "cn-hangzhou" のみをサポートしています
	  public static final String REGION_CN_HANGZHOU = "cn-hangzhou";
	  // 現在の sts api バージョン
	  public static final String STS_API_VERSION = "2015-04-01";
	  static AssumeRoleResponse assumeRole(String accessKeyId, String accessKeySecret,
	                                       String roleArn, String roleSessionName, String policy,
	                                       ProtocolType protocolType) throws ClientException {
	    try {
	      // OpenAPI を呼び出すための Alibaba Cloud Acs Client を構築します
	      IClientProfile profile = DefaultProfile.getProfile(REGION_CN_HANGZHOU, accessKeyId, accessKeySecret);
	      DefaultAcsClient client = new DefaultAcsClient(profile);
	      // AssumeRoleRequest オブジェクトを作成します
	      final AssumeRoleRequest request = new AssumeRoleRequest();
	      request.setVersion(STS_API_VERSION);
	      request.setMethod(MethodType.POST);
	      request.setProtocol(protocolType);
	      request.setRoleArn(roleArn);
	      request.setRoleSessionName(roleSessionName);
	      request.setPolicy(policy);
	      // リクエストを送信します
	      final AssumeRoleResponse response = client.getAcsResponse(request);
	      return response;
	    } catch (ClientException e) {
	      throw e;
	    }
	  }
	  public static void main(String[] args) {
	    // RAM ユーザー（サブアカウント）のみが AssumeRole インターフェースを呼び出すことができます
	    // Alibaba Cloud ルートアカウントの AccessKey は AssumeRole を呼び出すことができません
	    // RAM ウェブコンソール（https://ram.console.aliyun.com）でサブアカウントを作成し、このサブアカウントの AK を作成してください
	    String accessKeyId = "<subaccountaccesskey>";
	    String accessKeySecret = "<subaccountaccesssecret>";
	    // AssumeRole API パラメータ：RoleArn、RoleSessionName、Policy、および DurationSeconds
	    // RoleArn は RAM ウェブコンソールで取得できます
	    // https://ram.console.aliyun.com/#/role/detail/< specifid rolename>/info
	    String roleArn = "<ウェブコンソールで見つかった rolearn>";
	    // RoleSessionName は一時的なトークンです（主に監査に使用されます）
	    String roleSessionName = "bluemix-001";
	    String policy = "{\n" +
	            "    \"Version\": \"1\", \n" +
	            "    \"Statement\": [\n" +
	            "        {\n" +
	            "            \"Action\": \"log:PostLogStoreLogs\",\n" +
	            "            \"Resource\": \"*\",\n" +
	            "            \"Effect\": \"Allow\"\n" +
	            "        }\n" +
	            "    ]\n" +
	            "}";
	    System.out.println(policy);
	    // ここでは HTTPS のみをサポートしています
	    ProtocolType protocolType = ProtocolType.HTTPS;
	    AssumeRoleResponse response = new AssumeRoleResponse();
	    try {
	      response = assumeRole(accessKeyId, accessKeySecret,
	              roleArn, roleSessionName, policy, protocolType);
	      System.out.println("Expiration: " + response.getCredentials().getExpiration());
	      System.out.println("Access Key Id: " + response.getCredentials().getAccessKeyId());
	      System.out.println("Access Key Secret: " + response.getCredentials().getAccessKeySecret());
	      System.out.println("Security Token: " + response.getCredentials().getSecurityToken());
	    } catch (ClientException e) {
	      System.out.println("トークンの取得に失敗しました。");
	      System.out.println("エラーコード: " + e.getErrCode());
	      System.out.println("エラーメッセージ: " + e.getErrMsg());
	    }
	    
	    // Simple Log Service パラメータ
	    // Simple Log Service エンドポイントドキュメント：https://www.alibabacloud.com/help/ja/sls/developer-reference/api-sls-2020-12-30-endpoint
	    String logServiceEndpoint = "cn-hangzhou.log.aliyuncs.com";
	    // プロジェクトリージョンは cn-hangzhou である必要があります
	    String project = "<log service project name>";
	    String logstore = "<log service logstore name>";
	    
	    // Simple Log Service クライアントオブジェクトを構築します
	    Client client = new Client(logServiceEndpoint, 
	    		response.getCredentials().getAccessKeyId(), 
	    		response.getCredentials().getAccessKeySecret());
	    // 注意：AK とセキュリティトークンは 1 時間で有効期限が切れます
	    // 有効期限が切れたら asumeRole インターフェースを呼び出す必要があります
	    client.SetSecurityToken(response.getCredentials().getSecurityToken());
	    Vector<LogItem> logGroup = new Vector<LogItem>();
	    LogItem logItem = new LogItem((int) (new Date().getTime() / 1000));
	    logItem.PushBack("StsSample", "データを送信する"); //日本語化
	    logGroup.add(logItem);
	    
	    PutLogsRequest req2 = new PutLogsRequest(project, logstore, "", "", logGroup);
	    try {
	    	client.PutLogs(req2);
	    } catch (LogException e) {
			System.out.println("データの送信に失敗しました。"); //日本語化
			System.out.println("エラーコード: " + e.GetErrorCode());
			System.out.println("エラーメッセージ: " + e.GetErrorMessage());
	    }
	  }
}