in app/poller.py [0:0]
def handler(event, context):
"""Forward SQS messages to Kinesis Firehose Delivery Stream."""
for batch in _search_batches():
LAMBDA.invoke(
FunctionName=TWEET_PROCESSOR_FUNCTION_NAME,
InvocationType='Event',
Payload=json.dumps(batch)
)