in ChangeDataCapture/functions/ReplayFromStream.py [0:0]
def get_credentials(role_arn):
# create an STS client object that represents a live connection to the
# STS service
sts_client = boto3.client('sts')
# Call the assume_role method of the STSConnection object and pass the role
# ARN and a role session name.
assumed_role_object=sts_client.assume_role(
RoleArn=role_arn,
RoleSessionName="cross_acct_lambda"
)
# From the response that contains the assumed role, get the temporary
# credentials that can be used to make subsequent API calls
sts_response=assumed_role_object['Credentials']
return sts_response