File size: 707 Bytes
52bf3e0 39fe3d1 52bf3e0 93e74f7 39fe3d1 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
"""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():
"""
Returns a client connection to the AWS Glue service.
:return: AWS Glue client 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)
response = glue.start_job_run(
JobName='Reference China'
)
print(response)
|