能否从PostgreSQL数据库向Web API发送HTTP请求？拟用触发器实现新增记录时POST请求

当然可以实现！PostgreSQL本身没有自带直接发送HTTP请求的函数，但我们可以借助扩展或者自定义函数来搞定这个需求——尤其是你要在触发器里触发POST请求的场景，下面给你详细拆解可行的方案和关键注意事项：

最稳妥的方式是使用pg_net这个官方维护的PostgreSQL扩展，它专门用于处理异步HTTP请求，完美适配触发器场景（不会阻塞主事务）。

1. 安装pg_net扩展 #

首先在你的数据库中安装扩展：

CREATE EXTENSION IF NOT EXISTS pg_net;

2. 创建发送API请求的自定义函数 #

写一个PL/pgSQL函数，调用pg_net提供的net_http_post函数来发送异步POST请求：

CREATE OR REPLACE FUNCTION send_new_record_notification()
RETURNS TRIGGER AS $$
BEGIN
  -- 发送异步POST请求到你的API地址
  PERFORM net_http_post(
    'https://your-target-api.com/webhook', -- 替换成你的API端点
    row_to_json(NEW)::TEXT, -- 将新插入的记录转为JSON字符串作为请求体
    'application/json' -- 设置请求的Content-Type
  );
  RETURN NEW;
END;
$$ LANGUAGE plpgsql;

3. 创建触发器绑定到表 #

接下来创建触发器，当目标表有新记录插入时自动调用上面的函数：

CREATE TRIGGER trigger_after_insert_notify_api
AFTER INSERT ON your_table_name -- 替换成你要监控的表名
FOR EACH ROW
EXECUTE FUNCTION send_new_record_notification();

• 优先用异步请求：一定要避免用同步方式（比如直接调用curl），同步请求会阻塞数据库事务，导致插入操作变慢，甚至因为API超时引发数据库事务失败。pg_net的请求是后台异步执行的，完全不影响主事务的提交。
• 请求状态排查：pg_net会把所有请求和响应的状态存在net.http_requests和net.http_responses系统表里，你可以定期查询这两个表来追踪失败的请求，比如：

  SELECT * FROM net.http_responses WHERE status_code != 200;
  

• 权限与网络配置：确保数据库用户拥有执行pg_net函数的权限，同时数据库服务器的防火墙要允许出站请求到你的API地址。
• 数据格式适配：如果你的API需要特定的JSON结构，不用直接传row_to_json(NEW)，可以自己构造JSON对象，比如：

  json_build_object('id', NEW.id, 'name', NEW.name, 'created_at', NEW.created_at)::TEXT
  

如果因为权限或环境限制无法安装pg_net，也可以通过plsh（调用Shell命令）或者plpython等语言的函数来调用curl发送请求，但这种方式是同步阻塞的，生产环境不推荐：

CREATE OR REPLACE FUNCTION send_sync_api_request()
RETURNS TRIGGER AS $$
DECLARE
  curl_command TEXT;
BEGIN
  curl_command := 'curl -X POST -H "Content-Type: application/json" -d ''' || row_to_json(NEW)::TEXT || ''' https://your-target-api.com/webhook';
  PERFORM pg_catalog.pg_exec(curl_command);
  RETURN NEW;
END;
$$ LANGUAGE plsh;

这种方式的风险很高：API超时会导致数据库事务挂起，而且依赖服务器上的curl工具，稳定性较差。

内容的提问来源于stack exchange，提问作者barteloma