| """Trigger Parquet Snapshot Glue job""" | |
| import os | |
| import boto3 | |
| AWS_ACCESS_KEY_ID = os.environ['AWS_ACCESS_KEY_ID'] | |
| AWS_SECRET_ACCESS_KEY = os.environ['AWS_SECRET_ACCESS_KEY'] | |
| def get_client_connection(): | |
| """Get dynamoDB connection""" | |
| return boto3.client( | |
| service_name='glue', | |
| region_name='us-east-1', | |
| aws_access_key_id=AWS_ACCESS_KEY_ID, | |
| aws_secret_access_key=AWS_SECRET_ACCESS_KEY | |
| ) | |
| glue = get_client_connection() | |
| response = glue.start_job_run( | |
| JobName='Article Snapshot China' | |
| ) | |
| print(response) |