celery到logstash的日志和结构化日志
项目描述
# celstash
Celery日志记录到logstash和结构化日志(JSON)文件
请在此处提交错误 [here](https://github.com/CyberInt/celstash/issues)。
# 使用方法
import celstash
import logging
logger = celstash.new_logger('worker1', logstash_host='example.com')
logger.setLevel(logging.INFO)
logger.info('Money is the root of all evil, and man needs roots.')
# logstash 配置
input {
udp {
codec => json
}
}
output {
elasticsearch {
host => localhost # 修改为主机
}
}
# 许可证
MIT, see [LICENSE.txt](LICENSE.txt)
Celery日志记录到logstash和结构化日志(JSON)文件
请在此处提交错误 [here](https://github.com/CyberInt/celstash/issues)。
# 使用方法
import celstash
import logging
logger = celstash.new_logger('worker1', logstash_host='example.com')
logger.setLevel(logging.INFO)
logger.info('Money is the root of all evil, and man needs roots.')
# logstash 配置
input {
udp {
codec => json
}
}
output {
elasticsearch {
host => localhost # 修改为主机
}
}
# 许可证
MIT, see [LICENSE.txt](LICENSE.txt)