diff --git a/slack-bot/__pycache__/pullTrafficInfo.cpython-37.pyc b/slack-bot/__pycache__/pullTrafficInfo.cpython-37.pyc index 3a1df30..a8a9908 100644 Binary files a/slack-bot/__pycache__/pullTrafficInfo.cpython-37.pyc and b/slack-bot/__pycache__/pullTrafficInfo.cpython-37.pyc differ diff --git a/slack-bot/sendToSQS.py b/slack-bot/sendToSQS.py index 0827c14..7bd9367 100644 --- a/slack-bot/sendToSQS.py +++ b/slack-bot/sendToSQS.py @@ -38,16 +38,18 @@ for item in inst.output: message = sqs.send_message(QueueUrl=queueURL, MessageBody=encoded, 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.encode()) # 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')