tweeter.py 文件源码

def lambda_handler(event, context):
    # If being invoked by a dynamodb trigger
    if 'Records' in event:
        tweeters = dynamo_triggered_new_users(event)
        status = new_user_status
    else:  # If being invoked by the cron we scan the table
        tweeters = token_table.scan()['Items']

    for tweeter in tweeters:
        auth = OAuth1(
            creds['CONSUMER_KEY'],
            creds['CONSUMER_SECRET'],
            tweeter['oauth_token'],
            tweeter['oauth_token_secret']
        )
        resp = requests.post(
            "https://api.twitter.com/1.1/statuses/update.json",
            data={'status': status},
            auth=auth
        )
        if status == 200:
            print("Tweeted from " + tweeter['screen_name'])
        else:
            print(resp.text)