Setup and Running Kombu consumers
Steps:
- Install python 3.9 or greater on your system using pyenv
- Activate your project's virtual environment for installing this library
$ source <virtualenv-path>/bin/activate
- Install consumer library by running
$ pip install kube_kombu
If you are using django you'll need to setup the django project before running the consumer.
There are three variables that can be defined in your django settings file or in environment variables or as constants in your project:
RABBITMQ: This will be a dictionary containing rabbitmq related variables ####Example:
RABBITMQ = {
"URL": "<RABBIT_URL>",
"EXCHANGE": "<RABBIT_EXCHANGE>",
"EXCHANGE_TYPE": "<RABBIT_EXCHANGE_TYPE>",
"ROUTING_KEY": "<RABBIT_ROUTING_KEY>",
"QUEUE": "<RABBIT_QUEUE>"
}
HEALTHCHECK_HOST: Host on which the consumer thread will open a port fot liveness checkHEALTHCHECK_PORT: Port which will be opened by consumer thread for liveness check
Example
Sample scripts are written in the sample directory for defining and initializing the consumer
check_liveness_probe.py file is for testing the socket connection locally
You should now be able to use tcp liveness probe in kubernetes for liveness check of the pod.
202 Nov 19, 2022
205 Dec 30, 2022
35.1k Jan 2, 2023
8 Oct 25, 2022
19 May 6, 2022
8 Nov 26, 2022
2.4k Jan 4, 2023
1 Dec 2, 2021
2 Feb 11, 2022
1k Dec 28, 2022
52 Oct 30, 2022
5.8k Jan 02, 2023
1 Dec 20, 2021
106 Dec 25, 2022
">
13 Dec 20, 2022
68 Dec 22, 2022
1.2k Jan 03, 2023
152 Dec 25, 2022
2.1k Dec 29, 2022
2 Sep 06, 2022
13.3k Jan 01, 2023
1 Oct 22, 2021
10 Oct 22, 2022
70 Dec 31, 2022
2 Oct 15, 2021
62 Nov 30, 2022
1.6k Dec 30, 2022
40 Dec 23, 2022