Untitled
unknown
python
a year ago
1.7 kB
4
Indexable
import paho.mqtt.client as mqtt def on_connect(client, userdata, flags, rc): print("Connected with result code "+str(rc)) def on_publish(client, userdata, mid): pass def main(): broker = "mqtt.example.com" port = 1883 topic = "test" message = "Teste" num_messages = 100 client = mqtt.Client() client.on_connect = on_connect client.on_publish = on_publish client.connect(broker, port, 60) for i in range(num_messages): content = message client.publish(topic, content) client.disconnect() if __name__ == "__main__": main() ###################################################### ###################################################### import pika def main(): broker = "rabbitmq.example.com" message = "Teste" num_messages = 100 connection = pika.BlockingConnection(pika.ConnectionParameters(broker)) channel = connection.channel() channel.queue_declare(queue='hello') for i in range(num_messages): content = message channel.basic_publish(exchange='', routing_key='hello', body=content) connection.close() if __name__ == "__main__": main() ###################################################### ###################################################### from kafka import KafkaProducer def main(): broker = "kafka.example.com" topic = "test" message = "Teste" num_messages = 100 producer = KafkaProducer(bootstrap_servers=broker) for i in range(num_messages): content = message producer.send(topic, value=bytes(content, 'utf-8')) producer.close() if __name__ == "__main__": main()
Editor is loading...
Leave a Comment