KafkaLogs 0.0.11

Kakfa logging made simple with python, make your log messages as kafka events out-of-the-box!

Logging to kafka made simple with python.

1- Installation

• pip install KakfaLogs

• add .env file if not exist to the root directory of your project

2- Add the following configuration .env file

# ===================

# TEAM <abbreviations>

# de=data-engineering;ds=data science;se=software engineering

# APPLICATION_GROUP <abbreviations>

# tw=twitter

# nw=news;

# cv=covid-19

# ai=artificial intelligence

# ===================

# AGENT

# Allowed values <local> or <kafka>

# file –>> logs will be sent to .log file on specified location in DIR

# kafka –>> logs will be sent to kafka to specified topic and brokers

# ===================

CRITICAL=1

WARNING=2

INFO=3

ERROR=4

METRIC=5

DIR=/tmp/logs/

ENVIRONMENT=debug

APPLICATION=your_app

NOTIFY_URL=#

TEAM=de

APPLICATION_GROUP=tw

AGENT=kafka

KAFKA_BROKERS=localhost:9092

TOPIC=your_topic

3- Sample usage

import KafkaLogs as log

log.info(“hello there “)

dict = {“count”: 100, “date” : “2021-07-06”}

log.info(msg=”Yet another log!”, extra_data=dict)

log.error(“Opps! that’s an error.”)

log.critical(“Gosh! The application has encountered a fatal error!”)

log.warning(“That’s a warning!”)

dict = {“count”: 100}

log.metrics(msg=””, extra_data=dict)

License:MIT