Wie kafka producer laufen, der in Python geschrieben ist?

Question

Ich bin neu bei Kafka, habe aber ein paar Tutorials gesehen, damit ich weiß, wie Kafka funktioniert. Ich versuche, einen Producer zu starten, den ich in Python geschrieben habe, aber ich weiß nicht, wie ich diese Datei ausführen soll, nachdem ich meinen zokeeper Server und den kafka Server gestartet habe. Wenn mir jemand die Struktur des Befehls mitteilen kann, der in der Eingabeaufforderung geschrieben werden soll, würde ich es sehr begrüßen. Danke!

Kafka Hersteller:

import json 
import time 
from kafka import KafkaProducer 
from kafka.errors import KafkaError 
from kafka.future import log 

if __name__ == "__main__": 
    producer = KafkaProducer(bootstrap_servers= 'localhost: 9092') 

future = producer.send('my-topic', b"test") 

try: 
    record_metadata = future.get(timeout=10) 
except KafkaError : 
    log.exeption() 
    pass 

print(record_metadata.topic) 
print(record_metadata.partition) 
print(record_metadata.offset) 

producer = KafkaProducer(value_serializer = lambda m: json.dumps(m).encode('ascii')) 
producer.send('json-topic',{'key':'value'}) 

for _ in range (100): 
    producer.send('my-topic', b"test") 
    producer.send('my-topic',b"\xc2Hola, mundo!") 
    time.sleep(1) 

Answer 1

So wird Ihre Frage, wie ein Python-Skript ausführen? speichern Sie es einfach, machen ausführbare Datei und ausführen:

chmod +x ./kProducer.py 
python ./kproducer.py 

Weitere Einzelheiten sind hier: How to Run a Python Script via a File or the Shell

Answer 2

hinzufügen shebang Linie oben auf Ihr Skript:

#!/usr/bin/env python-version Ersetzen Sie die Python-Version mit python2 für 2.x und python3 für 3.x Um die Version von Python zu überprüfen, verwenden Sie den Befehl: python -V Die Shebang-Zeile wird die Skript-Fähigkeit bestimmen, um als eigenständiges Programm zu laufen. Dies wird hilfreich sein, wenn Sie auf das Skript doppelklicken und es ausführen möchten und nicht vom Terminal aus. oder einfach sagen

python scriptname.py