def createVPCEndpoints()

in remoteaccountpython/create-msk-vpc-endpoints.py [0:0]


def createVPCEndpoints(endpointService, ec2Client):
    try:
        response = ec2Client.create_vpc_endpoint(
            DryRun=False,
            VpcEndpointType='Interface',
            VpcId=vpcId,
            ServiceName=serviceEndpoint['Service_Endpoint_DNS'],
            SubnetIds=subnetIds,
            SecurityGroupIds=[
                endpointSecurityGroupId
            ],
            PrivateDnsEnabled=False,
            TagSpecifications=[
                {
                    'ResourceType': 'vpc-endpoint',
                    'Tags': [
                        {
                            'Key': 'Name',
                            'Value': 'MSK-Endpoint'
                        },
                    ]
                },
            ]
        )
        vpcEndpoint= response['VpcEndpoint']
        return vpcEndpoint
    except ClientError as err:
        print(err.response['Error'])