import requests
import json
from time import sleep
from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers=['master:9092'], api_version=(0, 10))
value = (133,144,232,54,2482,33228)
while True:
    try:
        for i in value:
            response = requests.get("https://api.coinlore.com/api/ticker/?id="+str(i))
            raw_stats = response.json()
            key_bytes = bytes(raw_stats[0]["name"], encoding='utf-8')
            value_bytes = bytes(raw_stats[0]["percent_change_1h"], encoding='utf-8')

            producer.send('warchulCurrency', key=key_bytes, value=value_bytes)
            producer.flush()

            print(raw_stats[0]["name"] + " - " + raw_stats[0]["percent_change_1h"])
            print()
            sleep(20)
    except:
        print("Blad")

producer.close()