B ǂ`% @s2ddlmZmZmZmZm Z Gddde j Z dS)) aws_lambda aws_dynamodbaws_iamaws_lambda_event_sourcescorecsDeZdZeddZeddZejeeeedfdd Z Z S) TweetsTablecCs|jS)N)_table)selfr D/Users/shuaicao/Documents/artifacts/ae-blog-cdk/ae/dynamodb_stack.pytable szTweetsTable.tablecCs|jS)N)_handler)r r r r handlerszTweetsTable.handler)scopeid table_name AE_THRESHOLD bucket_namec stj||f|tj|dtjdtjjddd|tjjt j j d|_ t j|ddt t dt d t d d |_|jt jd |jt jd |jt jdtj|dtjjtjdd|j||ddd|_|jtj|j tj!j"ddd|j #|jdS)NZTweetsr)nametype) partition_key read_capacitywrite_capacityrstreamremoval_policyZLambdaServiceRoleZLambdaServiceRoleForDDBzsagemaker.amazonaws.comzlambda.amazonaws.comzdynamodb.amazonaws.com) role_name assumed_byAmazonS3FullAccessZAmazonDynamoDBFullAccessAmazonSageMakerFullAccessZInferenceHandlerlambdazinference.lambda_handlerzHF-BERT-AE-model)ZPROJECT_BUCKET_NAMErZ ENDPOINT_NAME)runtimecoderrole environment i')starting_position batch_sizeretry_attempts)$super__init__ddbTable Attribute AttributeTypeNUMBERStreamViewTypeNEW_AND_OLD_IMAGESr RemovalPolicyDESTROYriamRoleCompositePrincipalServicePrincipalZ _lambda_iamadd_managed_policy ManagedPolicyfrom_aws_managed_policy_name_lambdaFunctionRuntime PYTHON_3_7Code from_assetr radd_event_sourcelambda_event_sourcesDynamoEventSourcer StartingPositionLATESTgrant_read_write_data)r rrrrrkwargs) __class__r r r*s@  zTweetsTable.__init__) __name__ __module__ __qualname__propertyr rr Constructstrr* __classcell__r r )rHr r s  rN) aws_cdkrr;rr+rr4rrBrrMrr r r r s