rocketmq-logger

    如果在短时间内没有收到日志数据，请放心，它会在我们的批处理处理器中的计时器功能到期后自动发送日志。

    有关 Apache APISIX 中 Batch-Processor 的更多信息，请参考。

    属性

    • default:
    • origin:
    1.     GET /hello?ab=cd HTTP/1.1
    2.     host: localhost
    3.     content-length: 6
    4.     connection: close

    消息将首先写入缓冲区。 当缓冲区超过 batch_max_size 时，它将发送到 rocketmq 服务器， 或每个 buffer_duration 刷新缓冲区。

    如果成功，则返回 true 。 如果出现错误，则返回 nil ，并带有描述错误的字符串（buffer overflow）。

    如何启用

    1. 为特定路由启用 rocketmq-logger 插件。
    2. {
    3.     "plugins": {
    4.        "rocketmq-logger": {
    5.            "nameserver_list" : [ "127.0.0.1:9876" ],
    6.            "topic" : "test2",
    7.        }
    8.     },
    9.     "upstream": {
    10.        "nodes": {
    11.            "127.0.0.1:1980": 1
    12.        },
    13.        "type": "roundrobin"
    14.     },
    15.     "uri": "/hello"
    16. }'

    成功

    插件元数据设置

    名称类型必选项默认值有效值描述
    log_formatobject可选{“host”: “$host”, “@timestamp”: “$time_iso8601”, “client_ip”: “$remote_addr”}以 JSON 格式的键值对来声明日志格式。对于值部分，仅支持字符串。如果是以 $ 开头，则表明是要获取 或 Nginx 内置变量。请注意，该设置是全局生效的，因此在指定 log_format 后，将对所有绑定 rocketmq-logger 的 Route 或 Service 生效。
    1. {
    3.         "host": "$host",
    4.         "@timestamp": "$time_iso8601",
    5.         "client_ip": "$remote_addr"
    6.     }
    7. }'

    在日志收集处，将得到类似下面的日志：

    1. $ curl http://127.0.0.1:9080/apisix/admin/routes/1  -H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -d '
    2. {
    3.     "methods": ["GET"],
    4.     "uri": "/hello",
    5.     "plugins": {},
    6.     "upstream": {
    7.         "type": "roundrobin",
    8.         "nodes": {
    9.             "127.0.0.1:1980": 1
    10.         }
    11. }'