You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
78 lines
2.3 KiB
78 lines
2.3 KiB
import boto3
|
|
import zipfile
|
|
|
|
################################################################################################
|
|
#
|
|
# Configuration Parameters
|
|
#
|
|
################################################################################################
|
|
|
|
# you need to create a bucket in S3, here in this demo it is called "cloudcomp-counter", but
|
|
# bucket names need to be world wide unique ;) The demo looks for a file that is named
|
|
# "us-east-1" (same as our default region) in the bucket and expects a number in it to increase
|
|
|
|
# region = 'eu-central-1'
|
|
region = 'us-east-1'
|
|
functionName = 'cloudcomp-counter-lambda-demo'
|
|
# roleName = 'arn:aws:iam::309000625112:role/service-role/cloudcomp-counter-demo-role-6rs7pah3'
|
|
roleName = 'arn:aws:iam::919927306708:role/cloudcomp-s3-access'
|
|
|
|
################################################################################################
|
|
#
|
|
# boto3 code
|
|
#
|
|
################################################################################################
|
|
|
|
|
|
client = boto3.setup_default_session(region_name=region)
|
|
lClient = boto3.client('lambda')
|
|
apiClient = boto3.client("apigatewayv2")
|
|
|
|
|
|
print("Deleting old function...")
|
|
print("------------------------------------")
|
|
try:
|
|
response = lClient.delete_function(
|
|
FunctionName=functionName,
|
|
)
|
|
except lClient.exceptions.ResourceNotFoundException:
|
|
print('Function not available. No need to delete it.')
|
|
|
|
|
|
print("creating new function...")
|
|
print("------------------------------------")
|
|
|
|
zf = zipfile.ZipFile('lambda-deployment-archive.zip', 'w', zipfile.ZIP_DEFLATED)
|
|
zf.write('lambda_function.py')
|
|
zf.close()
|
|
|
|
lambdaFunctionARN = ""
|
|
with open('lambda-deployment-archive.zip', mode='rb') as file:
|
|
zipfileContent = file.read()
|
|
|
|
response = lClient.create_function(
|
|
FunctionName=functionName,
|
|
Runtime='python3.8',
|
|
Role=roleName,
|
|
Code={
|
|
'ZipFile': zipfileContent
|
|
},
|
|
Handler='lambda_function.lambda_handler',
|
|
Publish=True,
|
|
)
|
|
lambdaFunctionARN = response['FunctionArn']
|
|
|
|
print("creating API gateway...")
|
|
print("------------------------------------")
|
|
|
|
#apiArn = ""
|
|
response = apiClient.create_api(
|
|
Name=functionName + '-api',
|
|
ProtocolType='HTTP',
|
|
Target=lambdaFunctionARN
|
|
)
|
|
#apiArn=response['']
|
|
|
|
#response = lClient.create_event_source_mapping(
|
|
# EventSourceArn=apiArn,
|
|
#)
|