我的ngx.timer.at不生效，代码如下，没有日志打印

winlia520 · 2017-03-03T16:19:23+00:00

你看下 ngx_http_file_cache_delete 里面会有个释放锁的动作，&#x7...

我的ngx.timer.at不生效，代码如下，没有日志打印

winlia520

local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

dingdongnigetou

你的time.at是靠什么触发的？request?还是init，初始化的话要放在init_worker_by_lua阶段。

On Friday, March 3, 2017 at 4:19:23 PM UTC+8, tan winfan wrote:


local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

winlia520

初始化我是放在init_worker_by_lua下面的

在 2017年3月3日星期五 UTC+8下午4:19:23，tan winfan写道：


local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

doujiang24

Hello

这类问题，你可以尝试使用更小的测试用例

另外错误日志也值得你去关注

2017-03-03 20:31 GMT+08:00 tan winfan <winl...@gmail.com>:

初始化我是放在init_worker_by_lua下面的

在 2017年3月3日星期五 UTC+8下午4:19:23，tan winfan写道：


local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

winlia520

doujiang，您好！！

我用最小化实例，也没能启动ngx.timer.at,但是我用 conten_by_lua_file能启动一个最小化实列定时器程序，也能打印日志

最小化实例程序如下

local delay = 3 -- in seconds

local new_timer = ngx.timer.at

local log = ngx.log

local ERR = ngx.ERR

local check

ngx.log(ngx.ALERT,"timer start!!!!")

check = function(premature)

ngx.log(ngx.ALERT,"CRON JOB!!!!")

if not premature then

-- do the health check or other routine work

local ok, err = new_timer(delay, check)

if not ok then

log(ERR, "failed to create timer: ", err)

return

end

local ok, err = new_timer(delay, check)

if not ok then

log(ERR, "failed to create timer: ", err)

return

end

上述程序在content_by_lua_file里，能正常运行，能打印日志，日志内容如下：

2017/03/03 21:47:05 [alert] 22343#0: [lua] v1.lua:23: CRON JOB!!!!, context: ngx.timer, client: 58.251.134.2, server: 0.0.0.0:80

2017/03/03 21:47:08 [alert] 22343#0: [lua] v1.lua:23: CRON JOB!!!!, context: ngx.timer, client: 58.251.134.2, server: 0.0.0.0:80

2017/03/03 21:47:11 [alert] 22343#0: [lua] v1.lua:23: CRON JOB!!!!, context: ngx.timer, client: 58.251.134.2, server: 0.0.0.0:80

2017/03/03 21:47:14 [alert] 22343#0: [lua] v1.lua:23: CRON JOB!!!!, context: ngx.timer, client: 58.251.134.2, server: 0.0.0.0:80

2017/03/03 21:47:17 [alert] 22343#0: [lua] v1.lua:23: CRON JOB!!!!, context: ngx.timer, client: 58.251.134.2, server: 0.0.0.0:80

但我把上面这段程序放到

http范围下就不启用，也没日志打印，

init_worker_by_lua '

local delay = 3 -- in seconds

local new_timer = ngx.timer.at

local log = ngx.log

local ERR = ngx.ERR

local check

ngx.log(ngx.ALERT,"timer start!!!!")

check = function(premature)

ngx.log(ngx.ALERT,"CRON JOB!!!!")

if not premature then

-- do the health check or other routine work

local ok, err = new_timer(delay, check)

if not ok then

log(ERR, "failed to create timer: ", err)

return

end

local ok, err = new_timer(delay, check)

if not ok then

log(ERR, "failed to create timer: ", err)

return

end

最后我怀疑我的init_worker_by_lua，init_worker_by_lua_file没生效，我的openresty 版本是如下,以及编译参数如下

resty 0.03

nginx version: openresty/1.9.7.2

built by gcc 4.4.7 20120313 (Red Hat 4.4.7-17) (GCC)

built with OpenSSL 1.0.1e-fips 11 Feb 2013

TLS SNI support enabled

configure arguments: --prefix=/data/webserver/openresty/nginx --with-cc-opt=-O2 --add-module=../ngx_devel_kit-0.2.19 --add-module=../echo-nginx-module-0.58 --add-module=../xss-nginx-module-0.05 --add-module=../ngx_coolkit-0.2rc3 --add-module=../set-misc-nginx-module-0.29 --add-module=../form-input-nginx-module-0.11 --add-module=../encrypted-session-nginx-module-0.04 --add-module=../srcache-nginx-module-0.30 --add-module=../ngx_lua-0.10.0 --add-module=../ngx_lua_upstream-0.04 --add-module=../headers-more-nginx-module-0.29 --add-module=../array-var-nginx-module-0.04 --add-module=../memc-nginx-module-0.16 --add-module=../redis2-nginx-module-0.12 --add-module=../redis-nginx-module-0.3.7 --add-module=../rds-json-nginx-module-0.14 --add-module=../rds-csv-nginx-module-0.07 --with-ld-opt=-Wl,-rpath,/data/webserver/openresty/luajit/lib --with-http_realip_module --with-http_stub_status_module --with-http_gzip_static_module --with-http_gzip_static_module --with-http_ssl_module --with-pcre --with-stream --with-stream_ssl_module --add-module=/usr/local/src/ngx_openresty-1.9.7.2/bundle/ngx_cache_purge-2.3 --add-module=/usr/local/src/ngx_openresty-1.9.7.2/bundle/nginx_upstream_check_module-0.3.0 --add-module=/usr/local/src/ngx_openresty-1.9.7.2/stream-lua-nginx-module-0.0.1

在 2017年3月3日星期五 UTC+8下午4:19:23，tan winfan写道：


local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

winlia520

这是我整个nginx.conf配置，请帮看看，thks

 
user omadmin nginx;
worker_processes 8;
worker_cpu_affinity 00000001 00000010 00000100 00001000 00010000 00100000 01000000 10000000;
pid /var/run/openresty.pid;
worker_rlimit_nofile 65535;
events {
       use epoll;
       worker_connections 65535;
       }

http { 
         include mime.types;
         #default_type application/octet-stream;
         charset utf-8;
         server_names_hash_bucket_size 128;
         client_header_buffer_size 32k;
         large_client_header_buffers 4 32k;
         client_max_body_size 500m;
         client_body_buffer_size 1024k;

         sendfile on;
         tcp_nopush on;

         keepalive_timeout 60;
         tcp_nodelay on;
         proxy_ignore_client_abort on;

         server_tokens off;
         fastcgi_connect_timeout 300;
         fastcgi_send_timeout 3000;
         fastcgi_read_timeout 3000;
         fastcgi_buffer_size 64k;
         fastcgi_buffers 4 64k;
         fastcgi_busy_buffers_size 128k;
         fastcgi_temp_file_write_size 128k;

         #gzip on;
         #gzip_min_length 1k;
         #gzip_buffers 4  16k;
         #gzip_http_version 1.0;
         #gzip_comp_level 2;
         #gzip_types text/plain application/x-_javascript_ text/css application/xml;
         #gzip_vary on;

         lua_package_path "/data/webserver/openresty/lualib/?.lua;;";

         log_format access '$remote_addr - $host $remote_user [$time_local] "$request" ' '$status $body_bytes_sent "$http_referer" ' 
         '"$http_user_agent" "$request_body" "$http_x_forwarded_for" - "$http_soapaction" "$upstream_response_time" "$request_time"';

         




init_by_lua '                                                                                                                                                                                                                               
        require "resty.core"
        template = require "resty.template"
        template.caching(true); -- you may remove this on production
      ';
init_worker_by_lua_file /data/www/atomic/app/cron_job.lua;

server {
       listen 80;
       server_name www.xxx.com;
       charset utf-8;
       #autoindex on;
       location = /favicon.ico {
       log_not_found off;
       access_log off;
       }

        set $template_location /templates;
        location /templates {
        internal;
        alias /data/www/atomic/static/;
        }

        set $path /data/www/atomic/app;

        location /v1/dx {
        default_type    'text/html';
        content_by_lua_file $path/dl.lua;
        log_by_lua_file $path/log_client.lua;
        }

         

        location /{
        default_type    'text/html';
        content_by_lua_file $path/v1.lua;
        }

      

       location ~ .*\.(gif|jpg|jpeg|png|bmp|swf)$
       {
       expires 30d;
       }
       location ~ .*\.(js|css)?$
       {
       expires 1h;
       }
       access_log /data/log/nginx/api.xxx.access.log access;
       error_log /data/log/nginx/api.xxx.error.log debug;
     }




     }



stream {
         server {
            listen 6678;
            content_by_lua_file /data/www/atomic/app/log_server.lua;
         }
       }

在 2017年3月3日星期五 UTC+8下午4:19:23，tan winfan写道：


local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

winlia520

doujiang, 我看了一下error log，除了我能看自己所配置的nginx error日志外，还能在哪看nginx的日志？

我准备打算重新编译一个1.9.7.5版本来试试，现在出了这个问题的是在公司另一台机器上面，我本机mac os x 跑完全可以的，

在 2017年3月3日星期五 UTC+8下午4:19:23，tan winfan写道：


local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

doujiang24

Hello

就是 nginx 的 error_log，注意你的日志错误级别别太高了，你可以尝试配置为 NOTICE 级别

如果是机器差异的话，你可以重新编译一个版本，先确认一下不是环境的问题，或者你测试的压根不是你预期的那个服务

在 2017年3月3日下午10:00，tan winfan <winl...@gmail.com>写道：

doujiang, 我看了一下error log，除了我能看自己所配置的nginx error日志外，还能在哪看nginx的日志？

我准备打算重新编译一个1.9.7.5版本来试试，现在出了这个问题的是在公司另一台机器上面，我本机mac os x 跑完全可以的，

在 2017年3月3日星期五 UTC+8下午4:19:23，tan winfan写道：


local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

winlia520

hello doujiang 您好！！

昨天己知道真真原因是因为我没有在nginx.conf中配置默认的

error /data/log/nginx/error.log, 导致日志打印不了

在 2017年3月3日星期五 UTC+8下午4:19:23，tan winfan写道：


local delay = 120 -- 每120秒执行
local run_time = "04" --每天早上4点运行脚本
local log_expire = 7 --保留7天历史数据

local handler
handler = function(premature)
    -- do some routine job in Lua just like a cron job
    local _time = os.date('%H', ngx.time())
    if _time == run_time then
        local db = hand_mysql:new(config.log_db_conf)
        local create_table_name_date = os.date('%Y%m%d', ngx.time() + 86400)
        local drop_table_name_date = os.date('%Y%m%d', ngx.time() - (log_expire * 86400))
        logdao.get_log_schema(db, create_table_name_date) --创建明天的表
        logdao.drop_log_data_table(db, drop_table_name_date) --删除7天以后的数据
    end
    ngx.log(ngx.ALERT, "cron job!")
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

--在worker id 为0的进程运行
if 0 == ngx.worker.id() then
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end