setup_infra.py 文件源码

def create_cw_event_trigger(session):
    client = session.client('dynamodb')
    rule_arn = []
    try:
        response = client.put_rule(
            Name='{}'.format(CW_RULE_NAME),
            ScheduleExpression='cron(0/10 * * * ? *)',
            Description='schedule ec2 lamabda function to run every 10 minutes.'
        )

        rule_arn = response['RuleArn']
        print "+ Created Cloud Watch Rule: ".format(rule_arn)

    except Exception as e:
        raise e

    return rule_arn