اتصال به RabbitMQ در برنامه‌های Django

pip install pika python-dotenv

# other codes ...
from dotenv import load_dotenv
load_dotenv()
# other codes ...

RABBITMQ_HOST=fitz-roy.liara.cloud
RABBITMQ_PORT=32923
RABBITMQ_USER=root
RABBITMQ_PASS=63LVuatIrWWajE7gxSj20gHL

import os
import pika
from dotenv import load_dotenv

load_dotenv()

RABBITMQ_HOST = os.getenv('RABBITMQ_HOST')
RABBITMQ_PORT = int(os.getenv('RABBITMQ_PORT'))
RABBITMQ_USER = os.getenv('RABBITMQ_USER')
RABBITMQ_PASS = os.getenv('RABBITMQ_PASS')

def check_rabbitmq_connection():
    try:
        credentials = pika.PlainCredentials(RABBITMQ_USER, RABBITMQ_PASS)
        parameters  = pika.ConnectionParameters(host=RABBITMQ_HOST, port=RABBITMQ_PORT, credentials=credentials)

        connection = pika.BlockingConnection(parameters)
        print("connection successful")

        
        connection.close()
    except Exception as e:
        print("connection failed, error:", e)

from django.http import HttpResponse
from .rabbitmq_utils import check_rabbitmq_connection

def test_rabbitmq_connection(request):
    check_rabbitmq_connection()
    return HttpResponse("RabbitMQ Connection Checked")

from . import views

urlpatterns = [
    path('test-rabbitmq/', views.test_rabbitmq_connection),
]

pip freeze > requirements.txt