Function poll

kafka2s3/crypto.py:14–22

(producer, topic)

import json

def poll(producer, topic):
	url = "https://api.nomics.com/v1/currencies/ticker?key={}&ids=BTC,ETH,XRP,DOGE,SHIB,BCH,BSV,LINK,LTC&interval=1d,30d&per-page=1000&page=1".format(os.getenv("NOMIC_API_KEY"))
	msgs = json.loads(urllib.request.urlopen(url).read())

	for msg in msgs:
		print(json.dumps(msg))
		key=bytes(msg['id'].encode('utf-8'))
		producer.send(topic, key=key, value=msg)
		producer.flush()


def main():