in Bot2/Poller/twitterPoller.py [0:0]
def build_send_sqs_message(screenName, tweetBody, mediaID, mediaURL):
# Get the queue
queue = sqs.get_queue_by_name(QueueName=queueName)
# Create the body of message in SQS
MessageBody="@"+screenName+ ": " + tweetBody
# Put attributes in SQS
MessageAttributes={
'mediaID': {
'DataType': 'String',
'StringValue': mediaID
},
'mediaURL': {
'DataType': 'String',
'StringValue': mediaURL
}
}
queue.send_message(MessageBody=MessageBody, MessageAttributes=MessageAttributes)