andyjk15/price-collector
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[23.09.2020] Convert Dict to Json

Browse Source
This commit is contained in:
Andy Sotheran 2020-09-23 21:16:20 +01:00
parent 89c110ac38
commit bf78fb7c40
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/pricing/collector.py
View File

@ -15,6 +15,8 @@ from pricing.exchanges.kraken import krakenVolAskBid, krakenHighLow, krakenOpenC
from src.utils.databaseConnect import send from src.utils.databaseConnect import send
from src.utils.activemqConnect import activeMQSender from src.utils.activemqConnect import activeMQSender
import json
import logging as logger import logging as logger
logger.basicConfig( logger.basicConfig(
@ -124,9 +126,11 @@ def sentToArtemis(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
"volume" : vol "volume" : vol
} }
messageJson = json.dumps(message, indent = 4)
logger.info("Sending message to PricingSave queue") logger.info("Sending message to PricingSave queue")
activeMQSender(message, logger) activeMQSender(messageJson, logger)
def timeFunction(): def timeFunction():