python_rabbitmq_send.py

# coding=utf-8

import pika
import environ

env = environ.Env()
environ.Env.read_env()
rabbitmq_url = env("RABBITMQ_URL")

params = pika.URLParameters(rabbitmq_url)
connection = pika.BlockingConnection(params)

channel = connection.channel()

channel.queue_declare(queue='intro_rabbitmq')

channel.basic_publish(exchange='', routing_key='intro_rabbitmq', body='Ola Mundo!')
print(" [x] Enviado 'Ola Mundo!'")
connection.close()