A package for pushing serialized error log which generated by loguru to remote storage.
A package for pushing serialized error log which generated by loguru to remote storage (including mongodb / redis / fluentd).
- parameters:
- mongo_instance(object): mongodb instance
- mongo_db(str): database for storing log data
- mongo_collection(str): collection for storing log data
- terminal_displayed(bool): display log information on terminal screen or not
- rotation(str): loguru rotation
- serialize(bool): data serialized or not
- log_format(str): loguru format
- log_path(str): file path for storing log data
- custom_func(function): function for custom serialized data
import json
from pymongo import MongoClient
from logger_master.logger import MongoLogger
# pushing log to mongodb instance
mongo_uri = 'mongodb://root:root@localhost:27017/?authMechanism=SCRAM-SHA-1'
mongo_instance = MongoClient(mongo_uri)
# basic usage for pushing log with specific database and collection
logger = MongoLogger(mongo_instance=mongo_instance,
mongo_db='my_log',
mongo_collection='my_log_collection')
# pushing serialize log to ./my_log/log_file
logger = MongoLogger(mongo_instance=mongo_instance,
mongo_db='my_log',
mongo_collection='my_log_collection',
serialize=True,
log_path='./my_log/log_file',
rotation='1 week')
# disable display log on screen
logger = MongoLogger(mongo_instance=mongo_instance,
mongo_db='my_log',
mongo_collection='my_log_collection',
log_path='./my_log/log_file',
terminal_displayed=False)
# pushing serialized log with custom format
def custom_function(serialized_data):
if not isinstance(serialized_data, dict):
serialized_data = json.loads(serialized_data)
serialized_data.update({'new_key': 'new_value'})
return serialized_data
logger = MongoLogger(mongo_instance=mongo_instance,
mongo_db='my_log',
mongo_collection='my_log_collection',
custom_func=custom_function)
try:
100 / 0
except Exception as e:
logger.error(str(e))
- parameters:
- redis_instance(object): redis instance
- key_prefix(str): prefix for redis key
- terminal_displayed(bool): display log information on terminal screen or not
- rotation(str): loguru rotation
- serialize(bool): data serialized or not
- log_format(str): loguru format
- log_path(str): file path for storing log data
- custom_func(function): function for custom serialized data
import json
import redis
from logger_master.logger import RedisLogger
# basic usage for pushing log to redis instance
redis_instance = redis.StrictRedis(host='localhost',
password='root',
port='root')
# pushing log to mongodb with 'my_error_log' key prefix
logger = RedisLogger(redis_instance=redis_instance,
key_prefix='my_error_log')
# pushing serialize log to ./my_log/log_file
logger = RedisLogger(redis_instance=redis_instance,
key_prefix='my_error_log',
serialize=True,
log_path='./my_log/log_file',
rotation='1 week')
# disable display log on screen
logger = RedisLogger(redis_instance=redis_instance,
key_prefix='my_error_log',
log_path='./my_log/log_file',
terminal_displayed=False)
# pushing serialized log with custom format
def custom_function(serialized_data):
if not isinstance(serialized_data, dict):
serialized_data = json.loads(serialized_data)
serialized_data.update({'new_key': 'new_value'})
return serialized_data
logger = RedisLogger(redis_instance=redis_instance,
key_prefix='my_error_log',
custom_func=custom_function)
try:
100 / 0
except Exception as e:
logger.error(str(e))
- parameters:
- hostname(str): fluentd hostname
- port(int): fluentd port
- key_prefix(str): prefix for fluentd key
- terminal_displayed(bool): display log information on terminal screen or not
- rotation(str): loguru rotation
- serialize(bool): data serialized or not
- log_format(str): loguru format
- log_path(str): file path for storing log data
- custom_func(function): function for custom serialized data
import json
from logger_master import FluentdLogger
# pushing log log to fluentd
# basic usage for pushing log data to fluentd
logger = FluentdLogger(hostname='localhost',
port=24224,
key_prefix='mongo')
# pushing serialize log to ./my_log/log_file
logger = FluentdLogger(hostname='localhost',
port=24224,
key_prefix='mongo',
serialize=True,
log_path='./my_log/log_file',
rotation='1 week')
# disable display log on screen
logger = FluentdLogger(hostname='localhost',
port=24224,
key_prefix='mongo',
log_path='./my_log/log_file',
terminal_displayed=False)
# pushing serialized log with custom format
def custom_function(serialized_data):
if not isinstance(serialized_data, dict):
serialized_data = json.loads(serialized_data)
serialized_data.update({'new_key': 'new_value'})
return serialized_data
logger = FluentdLogger(hostname='localhost',
port=24224,
key_prefix='mongo',
custom_func=custom_function)
try:
1 / 0
except Exception as e:
logger.error(msg=str(e))
you can also push log to both fluentd and mongodb with fluent-plugin-mongo.
Buy me a coffee, if you like it!