Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import boto3
- import time
- import json
- region = 'us-east-1'
- activity_arn = 'arn:aws:states:us-east-1:754185655346:activity:Process_Imagery'
- while True:
- client = boto3.client('stepfunctions', region_name=region)
- response = client.get_activity_task(activityArn=activity_arn,
- workerName='imagery_processor')
- activity_token = response['taskToken']
- input_params = json.loads(response['input'])
- print("================")
- print(input_params)
- client.send_task_success(taskToken=activity_token, output='true')
Add Comment
Please, Sign In to add comment