Untitled

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()