fin d'intégration de rabbitmq

elhadjbah · Sep 15, 2024 · 9437702 · 9437702
1 parent 24912ae
commit 9437702
Show file tree

Hide file tree

Showing 4 changed files with 28 additions and 28 deletions.
diff --git a/Dockerfile b/Dockerfile
@@ -2,32 +2,32 @@ FROM python:3.11-slim-buster
 
 WORKDIR /app
 
-# set environment variables
-ARG SECRET_KEY
-ARG DEBUG
-ARG ALLOWED_HOSTS_1
-ARG ALLOWED_HOSTS_2
-ARG CUSTOMER_API_URL
-ARG DB_HOST
-ARG MYSQL_PORT
-ARG MYSQL_ROOT_PASSWORD
-ARG MYSQL_DATABASE
-ARG MYSQL_USER
-ARG MYSQL_PASSWORD
-ARG MYSQL_TEST_DATABASE
-
-ENV SECRET_KEY=${SECRET_KEY}
-ENV DEBUG=${DEBUG}
-ENV ALLOWED_HOSTS_1=${ALLOWED_HOSTS_1}
-ENV ALLOWED_HOSTS_2=${ALLOWED_HOSTS_2}
-ENV CUSTOMER_API_URL=${CUSTOMER_API_URL}
-ENV DB_HOST=${DB_HOST}
-ENV MYSQL_PORT=${MYSQL_PORT}
-ENV MYSQL_ROOT_PASSWORD=${MYSQL_ROOT_PASSWORD}
-ENV MYSQL_DATABASE=${MYSQL_DATABASE}
-ENV MYSQL_USER=${MYSQL_USER}
-ENV MYSQL_PASSWORD=${MYSQL_PASSWORD}
-ENV MYSQL_TEST_DATABASE=${MYSQL_TEST_DATABASE}
+# # set environment variables
+# ARG SECRET_KEY
+# ARG DEBUG
+# ARG ALLOWED_HOSTS_1
+# ARG ALLOWED_HOSTS_2
+# ARG CUSTOMER_API_URL
+# ARG DB_HOST
+# ARG MYSQL_PORT
+# ARG MYSQL_ROOT_PASSWORD
+# ARG MYSQL_DATABASE
+# ARG MYSQL_USER
+# ARG MYSQL_PASSWORD
+# ARG MYSQL_TEST_DATABASE
+
+# ENV SECRET_KEY=${SECRET_KEY}
+# ENV DEBUG=${DEBUG}
+# ENV ALLOWED_HOSTS_1=${ALLOWED_HOSTS_1}
+# ENV ALLOWED_HOSTS_2=${ALLOWED_HOSTS_2}
+# ENV CUSTOMER_API_URL=${CUSTOMER_API_URL}
+# ENV DB_HOST=${DB_HOST}
+# ENV MYSQL_PORT=${MYSQL_PORT}
+# ENV MYSQL_ROOT_PASSWORD=${MYSQL_ROOT_PASSWORD}
+# ENV MYSQL_DATABASE=${MYSQL_DATABASE}
+# ENV MYSQL_USER=${MYSQL_USER}
+# ENV MYSQL_PASSWORD=${MYSQL_PASSWORD}
+# ENV MYSQL_TEST_DATABASE=${MYSQL_TEST_DATABASE}
 
 ENV PYTHONDONTWRITEBYTECODE 1
 ENV PYTHONUNBUFFERED 1

diff --git a/kawa_product/__pycache__/settings.cpython-311.pyc b/kawa_product/__pycache__/settings.cpython-311.pyc
diff --git a/services/__pycache__/rabbitmq_service.cpython-311.pyc b/services/__pycache__/rabbitmq_service.cpython-311.pyc
diff --git a/services/rabbitmq_service.py b/services/rabbitmq_service.py
@@ -7,7 +7,7 @@
 # Publier un message dans une queue RabbitMQ
 def publish_to_queue(queue_name, message):
     try:
-        connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+        connection = pika.BlockingConnection(pika.ConnectionParameters('host.docker.internal'))
         logger.debug("Connexion à RabbitMQ établie pour la publication")
         channel = connection.channel()
 
@@ -29,7 +29,7 @@ def publish_to_queue(queue_name, message):
 # Consommer des messages depuis une queue RabbitMQ
 def consume_from_queue(queue_name, callback):
     try:
-        connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+        connection = pika.BlockingConnection(pika.ConnectionParameters('host.docker.internal'))
         logger.info("Connexion à RabbitMQ établie pour la consommation")
         channel = connection.channel()