From 94b1a77bdc72c5a521579d1c556b534b6202b8ab Mon Sep 17 00:00:00 2001 From: marcsello Date: Wed, 18 Aug 2021 16:06:14 +0200 Subject: [PATCH] Changed routing key --- cnn_classification_service/config.py | 2 +- cnn_classification_service/main.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cnn_classification_service/config.py b/cnn_classification_service/config.py index 7baf953..bf17a26 100644 --- a/cnn_classification_service/config.py +++ b/cnn_classification_service/config.py @@ -6,7 +6,7 @@ import logging class Config: PIKA_URL = os.environ['PIKA_URL'] PIKA_OUTPUT_EXCHANGE = os.environ['PIKA_OUTPUT_EXCHANGE'] - PIKA_INPUT_EXCHANGE = os.environ['PIKA_INPUT_EXCHANGE'] + PIKA_INPUT_EXCHANGE = os.environ.get('PIKA_INPUT_EXCHANGE', 'sample-ready') MODEL_INFO_URL = os.environ.get("MODEL_INFO_URL", "http://model-service/model/cnn/$default") STORAGE_SERVICE_URL = os.environ.get("STORAGE_SERVICE_URL", "http://storage-service/") diff --git a/cnn_classification_service/main.py b/cnn_classification_service/main.py index 13dcd75..2828a2c 100644 --- a/cnn_classification_service/main.py +++ b/cnn_classification_service/main.py @@ -95,7 +95,7 @@ def main(): queue_declare_result = channel.queue_declare(queue='cnnqueue', exclusive=False) queue_name = queue_declare_result.method.queue - channel.queue_bind(exchange=Config.PIKA_INPUT_EXCHANGE, routing_key='feature', queue=queue_name) + channel.queue_bind(exchange=Config.PIKA_INPUT_EXCHANGE, routing_key='sample', queue=queue_name) channel.basic_qos(prefetch_count=1)