File size: 547 Bytes
52bf3e0
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
"""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)