a a#@s6ddlmZmZmZmZm Z m Z Gddde j Z dS))aws_iamaws_sqs aws_dynamodb aws_lambdaaws_lambda_event_sourcescorecs(eZdZejeddfdd ZZS)VsamToDynamoStackN)scope construct_idreturnc stj||fi|tj|dtjddd}tj|dtj dtj j ddd}t j |dt jjd t jd d }|||||t|dS) NZVsamToDynamoQueuei,)Zvisibility_timeoutZ queue_nameZCLIENTz CLIENT-KEY)nametype)Z partition_keyZ table_nameZSQSToDynamoFunctionzinsertRecord.handlerZ lambda_fns)runtimehandlercode)super__init___sqsZQueuerDurationseconds_dynZTable AttributeZ AttributeTypeSTRING_lambdaZFunctionZRuntimeZ PYTHON_3_9ZCode from_assetZgrant_write_dataZgrant_consume_messagesZadd_event_source_eventZSqsEventSource)selfr r kwargsqueueZ dynamoTableZ lambda_fn __class__o/Users/paulhene/devworkspace/serverless-patterns/sqs-lambda-dynamodb-cdk/vsam_to_dynamo/vsam_to_dynamo_stack.pyr s.     zVsamToDynamoStack.__init__)__name__ __module__ __qualname__r Constructstrr __classcell__r!r!rr"r srN)aws_cdkrZ_iamrrrrrrrrrStackrr!r!r!r"s