Kube kombu - Running kombu consumers with support of liveness probe for kubernetes

Last update: Dec 10, 2022

Related tags

Overview

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 check
HEALTHCHECK_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.

A Simple script to hunt unused Kubernetes resources.

K8SPurger A Simple script to hunt unused Kubernetes resources. Release History Release 0.3 Added Ingress Added Services Account Adding RoleBindding Re

202 Nov 19, 2022

Run Oracle on Kubernetes with El Carro

El Carro is a new project that offers a way to run Oracle databases in Kubernetes as a portable, open source, community driven, no vendor lock-in container orchestration system. El Carro provides a powerful declarative API for comprehensive and consistent configuration and deployment as well as for real-time operations and monitoring.

205 Dec 30, 2022

Linux, Jenkins, AWS, SRE, Prometheus, Docker, Python, Ansible, Git, Kubernetes, Terraform, OpenStack, SQL, NoSQL, Azure, GCP, DNS, Elastic, Network, Virtualization. DevOps Interview Questions

35.1k Jan 2, 2023

Chartreuse: Automated Alembic migrations within kubernetes

Releases(v1.0.6)

v1.0.6(Jan 31, 2022)

use sync_to_async
Source code(tar.gz)
Source code(zip)
v1.0.5(Jan 31, 2022)

Update connectivity check
Source code(tar.gz)
Source code(zip)
v1.0.4(Jan 31, 2022)

make connectivity method static
Source code(tar.gz)
Source code(zip)
v1.0.3(Jan 29, 2022)

Add connectivity check, which can be used in k8s liveness probe.
Source code(tar.gz)
Source code(zip)
v1.0.1(Jan 10, 2022)

Bump version to 1.0.1
Source code(tar.gz)
Source code(zip)
v1.0.0(Jan 10, 2022)

Detailed readme with organised codebase
Source code(tar.gz)
Source code(zip)
V1.0.2(Jan 10, 2022)

Update python required version to >=3.7
Source code(tar.gz)
Source code(zip)
v0.0.2(Jan 7, 2022)

Restructure code for readability
Source code(tar.gz)
Source code(zip)
v0.0.1(Jan 7, 2022)

TCP liveness probe can be added in kubernetes when the consumers are run using kube_kombu
Source code(tar.gz)
Source code(zip)

Kube kombu - Running kombu consumers with support of liveness probe for kubernetes

Related tags

Overview

Setup and Running Kombu consumers

Steps:

You might also like...

A Simple script to hunt unused Kubernetes resources.

Run Oracle on Kubernetes with El Carro

Linux, Jenkins, AWS, SRE, Prometheus, Docker, Python, Ansible, Git, Kubernetes, Terraform, OpenStack, SQL, NoSQL, Azure, GCP, DNS, Elastic, Network, Virtualization. DevOps Interview Questions

Chartreuse: Automated Alembic migrations within kubernetes

sysctl/sysfs settings on a fly for Kubernetes Cluster. No restarts are required for clusters and nodes.

Caboto, the Kubernetes semantic analysis tool

Hubble - Network, Service & Security Observability for Kubernetes using eBPF

Rancher Kubernetes API compatible with RKE, RKE2 and maybe others?

Quick & dirty controller to schedule Kubernetes Jobs later (once)

Releases(v1.0.6)

v1.0.6(Jan 31, 2022)

v1.0.5(Jan 31, 2022)

v1.0.4(Jan 31, 2022)

v1.0.3(Jan 29, 2022)

v1.0.1(Jan 10, 2022)

v1.0.0(Jan 10, 2022)

V1.0.2(Jan 10, 2022)

v0.0.2(Jan 7, 2022)

v0.0.1(Jan 7, 2022)

Owner

Anmol Porwal

Dynamic DNS service

Azure plugins for Feast (FEAture STore)

Travis CI testing a Dockerfile based on Palantir's remix of Apache Cassandra, testing IaC, and testing integration health of Debian

A tool to convert AWS EC2 instances back and forth between On-Demand and Spot billing models.

This Docker container is build to run on a server an provide an easy to use interface for every student to vote for their councilors

A colony of interacting processes

Hackergame nc 类题目的 Docker 容器资源限制、动态 flag、网页终端

A cpp project template that uses CMake to build and Google Test / Github Actions to provide a CI

HXVM - Check Host compatibility with the Virtual Machines

MicroK8s is a small, fast, single-package Kubernetes for developers, IoT and edge.

CI repo for building Skia as a shared library

Bugbane - Application security tools for CI/CD pipeline

Python job scheduling for humans.

Helperpod - A CLI tool to run a Kubernetes utility pod with pre-installed tools that can be used for debugging/testing purposes inside a Kubernetes cluster

a CLI that provides a generic automation layer for assessing the security of ML models

Ralph is the CMDB / Asset Management system for data center and back office hardware.

Lima is an alternative to using Docker Desktop on your Mac.

A Habitica Integration with Github Workflows.

A little script and trick to make your heroku app run forever without being concerned about dyno hours.

Supervisor process control system for UNIX