SmartF_BPS_Producer

from time import sleep
from json import dumps
from kafka import KafkaProducer

BPS_models = '/home/vybt/Downloads/release_official/full_flow_test/models.txt'

producer = KafkaProducer(bootstrap_servers=['localhost:9092'],
                         value_serializer=lambda x:
                         dumps(x).encode('utf-8'))

txt_file = open(BPS_models, "r")
count = 0
for person_url in txt_file:
    data = {'imagePersonURL' : str(person_url), 'ownerId': int(count)}
    count += 1
    print("sending ... {}".format(count))
    producer.send('bpsIn', value=data)