Gremlin JavaIAM와 함께 를 사용하여 Amazon Neptune 데이터베이스에 연결

IAM 사용자 또는 역할이 다른 역할을 수임할 수 있도록 허용하는 신뢰 정책을 사용하여 애플리케이션 AWS 계정에서 새 사용자 또는 역할을 생성합니다IAM. 애플리케이션을 호스팅하는 컴퓨팅(EC2인스턴스, Lambda 함수, ECS 태스크 등)에 이 역할을 할당합니다.

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "assume-role-policy",
            "Effect": "Allow",
            "Action": "sts:AssumeRole",
            "Resource": "(ARN of the role in the database account)"
        }
    ]
}

Neptune 데이터베이스에서 Neptune 데이터베이스에 대한 액세스를 허용하고 애플리케이션 AWS 계정 IAM 사용자/역할의 역할 가정을 허용하는 새 IAM 역할을 생성합니다. 신뢰 정책 사용:

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "AWS": [
                    "(ARN of application account IAM user or role)"
                ]
            },
            "Action": "sts:AssumeRole",
            "Condition": {}
        }
    ]
}

다음 코드 예제를 사용하여 애플리케이션이 Neptune에 액세스하도록 허용하는 데 이 두 역할을 사용하는 방법에 대한 지침으로 사용합니다. 이 예제에서는 를 생성할 DefaultCredentialProviderChain 때 를 통해 애플리케이션 계정 역할을 맡습니다STSclient. 그런 다음 를 통해 STSclient 를 사용하여 Neptune 데이터베이스 AWS 계정에서 호스팅되는 역할을 STSAssumeRoleSessionCredentialsProvider 수임합니다.

public static void main( String[] args )
  {

    /* 
     * Establish an STS client from the application account.
     */
    AWSSecurityTokenService client = AWSSecurityTokenServiceClientBuilder
        .standard()
        .build();

    /*
     * Define the role ARN that you will be assuming in the database account where the Neptune cluster resides.
     */
    String roleArnToAssume = "arn:aws:iam::012345678901:role/CrossAccountNeptuneRole";
    String crossAccountSessionName = "cross-account-session-" + UUID.randomUUID();

    /*
     * Change the Credentials Provider in the SigV4 Signer to use the STSAssumeRole Provider and provide it
     * with both the role to be assumed, the original STS client, and a session name (which can be
     * arbitrary.)
     */
    Cluster cluster = Cluster.build()
                 .addContactPoint("neptune-cluster.us-west-2.neptune.amazonaws.com")
                 .enableSsl(true)
                 .port(8182)
                 .handshakeInterceptor( r ->
                  {
                    try {
                      NeptuneNettyHttpSigV4Signer sigV4Signer =
                        // new NeptuneNettyHttpSigV4Signer("us-west-2", new DefaultAWSCredentialsProviderChain());
                        new NeptuneNettyHttpSigV4Signer(
                                "us-west-2",  
                                 new STSAssumeRoleSessionCredentialsProvider
                                    .Builder(roleArnToAssume, crossAccountSessionName)
                                        .withStsClient(client)
                                        .build());
                      sigV4Signer.signRequest(r);
                    } catch (NeptuneSigV4SignerException e) {
                      throw new RuntimeException("Exception occurred while signing the request", e);
                    }
                    return r;
                  }
                 ).create();

    GraphTraversalSource g = traversal().withRemote(DriverRemoteConnection.using(cluster));

    /* whatever application code is necessary */

    cluster.close();
  }