From bf78fb7c40536c26547511207e32b6668bad6219 Mon Sep 17 00:00:00 2001 From: Andy Sotheran Date: Wed, 23 Sep 2020 21:16:20 +0100 Subject: [PATCH] [23.09.2020] Convert Dict to Json --- src/pricing/collector.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/pricing/collector.py b/src/pricing/collector.py index 6c62cac..7328635 100644 --- a/src/pricing/collector.py +++ b/src/pricing/collector.py @@ -15,6 +15,8 @@ from pricing.exchanges.kraken import krakenVolAskBid, krakenHighLow, krakenOpenC from src.utils.databaseConnect import send from src.utils.activemqConnect import activeMQSender +import json + import logging as logger logger.basicConfig( @@ -124,9 +126,11 @@ def sentToArtemis(c_type, timestamp, av_price, high, low, vol, o_price, c_price) "volume" : vol } + messageJson = json.dumps(message, indent = 4) + logger.info("Sending message to PricingSave queue") - activeMQSender(message, logger) + activeMQSender(messageJson, logger) def timeFunction():