当openresty lua_code_cache on的时候日志无法推送到rsyslog

xuehuawuhen · 2018-07-26T12:36:27+00:00

消息太多，退订-- 王传波 salmonlM +8610-15810185242A 北京市海&#x...

当openresty lua_code_cache on的时候日志无法推送到rsyslog

xuehuawuhen

日志收集，我是严格按照文档上来的，但是当openresty lua_code_cache on的时候日志无法推送到rsyslog，如果为off ，则一切正常

https://moonbingbing.gitbooks.io/openresty-best-practices/ngx_lua/log.html

这段代码一定是写在log阶段的，请大神帮忙看看什么原因呢？

openresty 1.11 和1.13 都是这样子的。

local logger = require "./resty.socket"
local json = require "cjson"
if not logger.initted() then
    local ok, err = logger.init{
        host = '127.0.0.1',
        port = 514,
        flush_limit = 1,
        drop_limit = 5000,
--        periodic_flush = 1,
    }

    if not ok then
        ngx.log(ngx.ERR, "failed to initialize the logger: ", err)
        return
    end
    local querys = ngx.req.get_uri_args()

    local data = {
        name=111,
        name2="name2",
       query=querys
    }
    local json = json.encode(data)
    ngx.log(ngx.DEBUG, #json, 'rsyslog-json length')
    local bytes, err = logger.log(json)
    ngx.log(ngx.DEBUG, json, 'rsyslog-json')
    ngx.log(ngx.DEBUG, bytes, 'bytesbytes')
    if err then
        ngx.log(ngx.ERR, "failed to log message: ", err)
    end
end

jinhailang2008

建议你看下 `resty.socket` 源码，`initted` 实际返回的是 模块变量 `logger.initted`。lua_code_cache on 开启 lua 代码缓存，模块变量也就被缓存住了。

也就是说（单个 worker）第一个请求执行 init 成功之后，后面的请求都不会进 if 里面的逻辑了。

可以修改为：

if not logger.initted() then

local ok, err = logger.init{

host = '127.0.0.1',

port = 514,

flush_limit = 1,

drop_limit = 5000,

-- periodic_flush = 1,

}

if not ok then

ngx.log(ngx.ERR, "failed to initialize the logger: ", err)

return

end

}

// todo

在 2018年7月26日星期四 UTC+8下午12:36:27，任仪能写道：

日志收集，我是严格按照文档上来的，但是当openresty lua_code_cache on的时候日志无法推送到rsyslog，如果为off ，则一切正常

https://moonbingbing.gitbooks.io/openresty-best-practices/ngx_lua/log.html

这段代码一定是写在log阶段的，请大神帮忙看看什么原因呢？

openresty 1.11 和1.13 都是这样子的。

local logger = require "./resty.socket"
local json = require "cjson"
if not logger.initted() then
    local ok, err = logger.init{
        host = '127.0.0.1',
        port = 514,
        flush_limit = 1,
        drop_limit = 5000,
--        periodic_flush = 1,
    }

    if not ok then
        ngx.log(ngx.ERR, "failed to initialize the logger: ", err)
        return
    end
    local querys = ngx.req.get_uri_args()

    local data = {
        name=111,
        name2="name2",
       query=querys
    }
    local json = json.encode(data)
    ngx.log(ngx.DEBUG, #json, 'rsyslog-json length')
    local bytes, err = logger.log(json)
    ngx.log(ngx.DEBUG, json, 'rsyslog-json')
    ngx.log(ngx.DEBUG, bytes, 'bytesbytes')
    if err then
        ngx.log(ngx.ERR, "failed to log message: ", err)
    end
end