请教log_by_lua_file 阶段使用resty.http

alex10630 · 2017-03-13T16:57:28+00:00

Hello在 2017年3月13日下午4:53，wwaz wwaz <3824...@qq.com>写道：1 一条连&...

请教log_by_lua_file 阶段使用resty.http

alex10630

手边有个需求, 希望nginx直接把日志发送到elasticsearch内. 在github上找到了一个解决方法, https://github.com/bdeak/nginx-log-elasticsearch-lua ,但是跑不起来.

所以打算自己写一个简单的实现, 使用的resty.http .在log_by_lua_file 使用,提示API disabled in the current context. 网上找了下解决方法,说是通过ngx.timer.at的方式来搞定.

教程里例子给的很简单. 照抄回来以后,发现还是提示API disabled in the current context....

--------------------------------------------

local json = require "cjson"

local http = require "resty.http"

local httpc = http.new()

httpc:set_timeout(500)

httpc:connect("192.168.0.100",9200)

local ok,err = httpc:request {

path = "/" .. esindex .. "/" .. estype,

method = "POST",

-- body = json.encode(logdata),

body = logdata,

}

if not ok then

ngx.log(ngx.ERR,"ES error:",err)

end

local ok, err = ngx.timer.at(0, sendlog)

if not ok then

ngx.log(ngx.ERR,"ES err:",err)

return

end

-----------------------------

求大神解救...谢谢

huang_hua2012

hello，或者demo类似这个：

local sendlog

sendlog = function()

local json = require "cjson"
local http = require "resty.http"
local httpc = http.new()
httpc:set_timeout(500)
httpc:connect("192.168.0.100",9200)
local ok,err = httpc:request {
path = "/" .. esindex .. "/" .. estype,
method = "POST",
-- body = json.encode(logdata),
body = logdata,
}
if not ok then
ngx.log(ngx.ERR,"ES error:",err)
end

ngx.timer.at(0,sendlog)

end

local ok, err = ngx.timer.at(0, sendlog)
if not ok then
ngx.log(ngx.ERR,"ES err:",err)
return
end

在 2017年3月13日，下午4:57，aLeX Lee <alex...@gmail.com> 写道：

手边有个需求, 希望nginx直接把日志发送到elasticsearch内. 在github上找到了一个解决方法, https://github.com/bdeak/nginx-log-elasticsearch-lua ,但是跑不起来.
所以打算自己写一个简单的实现, 使用的resty.http .在log_by_lua_file 使用,提示API disabled in the current context. 网上找了下解决方法,说是通过ngx.timer.at的方式来搞定.
教程里例子给的很简单. 照抄回来以后,发现还是提示API disabled in the current context....

--------------------------------------------
local json = require "cjson"
local http = require "resty.http"
local httpc = http.new()
httpc:set_timeout(500)
httpc:connect("192.168.0.100",9200)
local ok,err = httpc:request {
path = "/" .. esindex .. "/" .. estype,
method = "POST",
-- body = json.encode(logdata),
body = logdata,
}
if not ok then
ngx.log(ngx.ERR,"ES error:",err)
end

end

local ok, err = ngx.timer.at(0, sendlog)
if not ok then
ngx.log(ngx.ERR,"ES err:",err)
return
end

-----------------------------

求大神解救...谢谢

--
--

qleex001

可以参考下lua-resty-logger-socket的做法

https://github.com/cloudflare/lua-resty-logger-socket

在 2017年3月13日星期一 UTC+8下午4:57:28，aLeX Lee写道：

手边有个需求, 希望nginx直接把日志发送到elasticsearch内. 在github上找到了一个解决方法, https://github.com/bdeak/nginx-log-elasticsearch-lua ,但是跑不起来.
所以打算自己写一个简单的实现, 使用的resty.http .在log_by_lua_file 使用,提示API disabled in the current context. 网上找了下解决方法,说是通过ngx.timer.at的方式来搞定.
教程里例子给的很简单. 照抄回来以后,发现还是提示API disabled in the current context....

--------------------------------------------
local json = require "cjson"
local http = require "resty.http"
local httpc = http.new()
httpc:set_timeout(500)
httpc:connect("192.168.0.100",9200)
local ok,err = httpc:request {
path = "/" .. esindex .. "/" .. estype,
method = "POST",
-- body = json.encode(logdata),
body = logdata,
}
if not ok then
ngx.log(ngx.ERR,"ES error:",err)
end

end

local ok, err = ngx.timer.at(0, sendlog)
if not ok then
ngx.log(ngx.ERR,"ES err:",err)
return
end

-----------------------------

求大神解救...谢谢