到 Elasticsearch 服务器,可以按照以下步骤操作:
- 安装 loguru 和 elasticsearch 模块:
pip install loguru
pip install elasticsearch
- 在代码中引入 loguru 和 elasticsearch 模块:
from loguru import logger
from elasticsearch import Elasticsearch
- 配置 Elasticsearch 连接:
es = Elasticsearch(
hosts=["http://<es_host>:<es_port>"],
http_auth=("username", "password")
)
其中,<es_host> 和 <es_port> 分别为 Elasticsearch 服务器的主机名和端口号,username 和 password 是连接 Elasticsearch 的用户名和密码。
- 添加 loguru 日志处理器,将日志发送到 Elasticsearch:
logger.add(
lambda message: es.index(
index="my-index",
body={
"timestamp": message.timestamp.isoformat(),
"level": message.level.name,
"message": message.message,
"extra": message.extra,
}
),
level="DEBUG"
)
其中,index 参数指定要发送日志数据的 Elasticsearch 索引名称,body 参数是要发送的日志数据。在这里,我们将日志消息、级别和时间戳作为 Elasticsearch 文档的字段,并添加了额外的字段(如果有)。
- 记录日志:
logger.debug("This is a debug message", extra={"user_id": 123})
logger.info("This is an info message")
logger.warning("This is a warning message")
logger.error("This is an error message", extra={"user_id": 456})
logger.critical("This is a critical message")
在记录日志时,可以使用 extra 参数添加额外的字段。这些字段将被包含在 Elasticsearch 文档中。
- 查看日志:
可以使用 Elasticsearch 的 Kibana 工具或其他 Elasticsearch 客户端来查看发送到 Elasticsearch 的日志。




