Postgres PGQ扩展消费者函数未触发问题求助（PGQ v3.5+Postgres15）

核心问题：PGQ消费者不会自动执行，需手动/守护进程触发 #

PGQ的消费者函数不会自动触发，仅注册消费者和获取批次不足以执行事件处理逻辑，必须通过以下方式之一启动处理流程：

1. 检查pgqd守护进程是否运行 #

pgqd是PGQ的核心守护进程，负责自动拉取批次并调用消费者函数。如果没有启动pgqd，消费者永远不会被触发：

• 查看pgqd进程状态：ps aux | grep pgqd
• 启动pgqd（根据安装路径调整）：pgqd -d -c /path/to/pgqd.conf

2. 手动触发消费者函数（测试用） #

如果只是测试，可手动调用消费者函数处理已获取的批次：
假设pgq.next_batch返回的batch_id为1，执行：

SELECT * FROM email_consumer4('email_queue4', 1, 10);

执行后检查是否发送邮件，同时查看Postgres日志是否有报错。

3. 确认批次与事件状态 #

• 验证事件是否成功插入队列：

SELECT * FROM pgq_event 
WHERE ev_queue = (SELECT q_id FROM pgq_queue WHERE q_name = 'email_queue4');

• 检查批次是否被正确分配：

SELECT * FROM pgq_batch 
WHERE b_queue = (SELECT q_id FROM pgq_queue WHERE q_name = 'email_queue4')
AND b_consumer = (SELECT co_id FROM pgq_consumer WHERE co_name = 'email_consumer4');

4. 排查消费者函数执行错误 #

• 直接调用函数测试，查看是否有语法或逻辑错误：

BEGIN;
SELECT * FROM email_consumer4('email_queue4', (SELECT batch_id FROM pgq.next_batch_info('email_queue4', 'email_consumer4')), 10);
ROLLBACK; -- 测试用，避免重复处理

• 检查Postgres日志（通常在pg_log目录），看是否有send_email函数报错（比如SMTP连接失败、参数错误）。

5. 验证消费者注册状态 #

确认消费者已正确绑定到队列：

SELECT * FROM pgq_consumer 
WHERE co_queue = (SELECT q_id FROM pgq_queue WHERE q_name = 'email_queue4')
AND co_name = 'email_consumer4';

补充建议 #

• 确保send_email函数能独立执行成功：先单独调用send_email测试邮件发送功能，排除邮件服务本身的问题。
• PGQ v3.5文档明确要求，消费者函数需由pgqd或手动调用触发，不要依赖自动执行。

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