From 73e2eaaf70d5b1a31088c0dcb9a5ba61d068e36b Mon Sep 17 00:00:00 2001 From: Fred Heincke Date: Fri, 25 Apr 2025 06:47:00 +0000 Subject: [PATCH] Add support for RabbitMQ connection string to the Scanner service Signed-off-by: Fred Heincke --- scanner/.env.example | 12 ++++++++++++ scanner/providers/rabbit_base.py | 1 + 2 files changed, 13 insertions(+) create mode 100644 scanner/.env.example diff --git a/scanner/.env.example b/scanner/.env.example new file mode 100644 index 00000000..90b614e7 --- /dev/null +++ b/scanner/.env.example @@ -0,0 +1,12 @@ +# vi: ft=sh +# shellcheck disable=SC2034 + +# RabbitMQ settings +# URL examples: https://docs.aio-pika.com/#url-examples +# This uses AIORMQ (https://github.com/mosquito/aiormq/) under the hood, and supports whatever the library supports. +# RABBITMQ_URL=ampqs://user:password@rabbitmq-server:1234/vhost?capath=/path/to/cacert.pem&certfile=/path/to/cert.pem&keyfile=/path/to/key.pem +# These values are ignored when the RABBITMQ_URL is set +RABBITMQ_HOST=rabbitmq +RABBITMQ_PORT=5672 +RABBITMQ_USER=guest +RABBITMQ_PASSWORD=guest diff --git a/scanner/providers/rabbit_base.py b/scanner/providers/rabbit_base.py index ff29c4f1..120989a2 100644 --- a/scanner/providers/rabbit_base.py +++ b/scanner/providers/rabbit_base.py @@ -7,6 +7,7 @@ class RabbitBase: async def __aenter__(self): self._con = await connect_robust( + os.environ.get("RABBITMQ_URL"), host=os.environ.get("RABBITMQ_HOST", "rabbitmq"), port=int(os.environ.get("RABBITMQ_PORT", "5672")), login=os.environ.get("RABBITMQ_DEFAULT_USER", "guest"),