Kakfa logging made simple with python, make your log messages as kafka events out-of-the-box!
Project description
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
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.