dtomlinson/python-VM
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

updating sendToSQS.py

Browse Source
This commit is contained in:
Daniel Tomlinson
2019-10-06 03:16:27 +01:00
parent 6cc36b0af9
commit 217efe3c20
2 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
slack-bot/__pycache__/pullTrafficInfo.cpython-37.pyc
View File

Binary file not shown.

22
slack-bot/sendToSQS.py
View File

@@ -38,16 +38,18 @@ for item in inst.output:
message = sqs.send_message(QueueUrl=queueURL, message = sqs.send_message(QueueUrl=queueURL,
MessageBody=encoded, MessageBody=encoded,
MessageGroupId=f'slack-bot-{motorway}') MessageGroupId=f'slack-bot-{motorway}')
response = sqs.receive_message(QueueUrl=queueURL,
MaxNumberOfMessages=5)
if 'Messages' in response:
for message in response['Messages']:
# print(message['Body'])
# break
decoded = base64.b64decode(message['Body'].encode())
print(decoded.decode())
else:
print('Queue is empty')
# print(encoded) # print(encoded)
# print(encoded.encode()) # print(encoded.encode())
# print(base64.b64decode(encoded.encode()).decode()) # print(base64.b64decode(encoded.encode()).decode())
response = sqs.receive_message(QueueUrl=queueURL,
MaxNumberOfMessages=4)
if 'Messages' in response:
for message in response['Messages']:
# print(message['Body'])
# break
decoded = base64.b64decode(message['Body'].encode())
print(decoded.decode())
else:
print('Queue is empty')