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'])