如何在nginx内部发送接口请求呢？

Question

问题场景：
我想实现在nginx的upstream服务组中获取当服务器是否轮询到了backup；如果轮询到我就在nginx的配置文件中发送一个接口请求，类似于飞书(钉钉)的消息通知 告诉当前的服务已经backup了

实现的方式：
我本地是mac的开发环境下载了openresry通过lua脚本进行请求接口，下载了resty.http实现了请求，因为请求的地址是https的，我本地使用mkcert生成了一个免费的SSL的证书，但是请求的时候一直报错：无法解析域名；

下方是伪代码：

worker_processes  1;

error_log  /usr/local/etc/openresty/logs/error.log;
error_log  /usr/local/etc/openresty/logs/info.log info;


events {
    worker_connections  1024;
}

http {
    include       mime.types;
    default_type  application/octet-stream;

    sendfile        on;
    keepalive_timeout  65;

    server {
        listen 443 ssl;
        listen [::]:443 ssl;
        server_name demo.com;

        ssl_certificate      /Users/yangfan/demo.com.pem;
        ssl_certificate_key  /Users/yangfan/demo.com-key.pem;

        location / {
            root   html;
            index  index.html index.htm;
        }

        location /fs {
            content_by_lua_file /usr/local/etc/openresty/tests/upstream.lua;
        }

        error_page   500 502 503 504  /50x.html;
        location = /50x.html {
            root   html;
        }
    }
}

lua的代码：

local http = require "resty.http"
local cjson = require "cjson"
local httpc = http.new()

local userData = {
    msg_type = "post",
    content = {
        post = {
            zh_cn = {
                title = "222",
                content = {
                    {
                        tag = "text",
                        text = "222222",
                    },
                    {
                        tag = "at",
                        user_id = "all",
                    },
                },
            },
        },
    },
}
local jsonStr = cjson.encode(userData)


local res, err = httpc:request_uri("https://open.f.xxxx.cn/open-apis/bot/v2/hook/xxxxxx", {
    method = "POST",
    body = jsonStr,
    headers = {
        ["Content-Type"] = "application/json",
    },
})

if res == nil then
    ngx.log(ngx.INFO,"=====================>>>>>>>>>>>>>>>>>1111111111 ".. err)
else
    ngx.log(ngx.INFO,"=====================>>>>>>>>>>>>>>>>>000000000000 ".. res)
    ngx.log(ngx.INFO,"=====================>>>>>>>>>>>>>>>>>33333333333333 ".. err)
end

疑惑：

• 目前整个链路是对的吗？我是本地启动openresty进行访问的？
• 还有别的方式可以实现我当前的需求吗？

Answer 1

你应该做的是在nginx之外持续的ping primary 是不是不通。

监控系统应该游离在系统之外

Answer 2

可以参考下
1、nginx-vts-exporter 可以拿到upstream的状态 比如upstream requests，那么upstream的地址是固定的，并且可以精确定位IP的话 可以使用promql写告警 （promql示例：sum(upstream_requests{ip="192.168.1.1"}[5m])）

2、同1类似，已知upstream backup的IP，反向而行之 在backup这台机器简单个脚本实现呢？
ChatGPT写的

#!/bin/bash

# 日志文件路径
LOG_FILE="/var/log/nginx/access.log"

# 保存上次检查的位置的文件
POSITION_FILE="/tmp/nginx_access_log_position"

# 告警函数，可以根据需求调整，如发送邮件、消息通知等
send_alert() {
  echo "New log entries detected!"
  # 在这里添加你的告警代码，比如发送邮件或其他通知方式
  # mail -s "Nginx Log Alert" [e-mail] <<< "New log entries detected in Nginx access log."
}

# 如果位置文件不存在，创建它并初始化为0
if [ ! -f $POSITION_FILE ]; then
  echo 0 > $POSITION_FILE
fi

# 获取上次检查的位置
LAST_POS=$(cat $POSITION_FILE)

# 获取当前文件的大小
CURRENT_SIZE=$(stat -c%s "$LOG_FILE")

# 比较当前文件大小与上次检查位置
if [ $CURRENT_SIZE -gt $LAST_POS ]; then
  # 如果文件有新增，读取新增的部分
  NEW_LOG=$(tail -c +$((LAST_POS + 1)) "$LOG_FILE")
  
  # 处理新增的日志，可以在这里添加处理逻辑
  # 比如筛选特定的日志或记录到其他地方
  echo "$NEW_LOG"

  # 发送告警
  send_alert
  
  # 更新位置文件
  echo $CURRENT_SIZE > $POSITION_FILE
fi