Python接收PostgreSQL LISTEN通知时device_snapshot_change通道无响应问题

以下是可按优先级执行的排查步骤：

• 优先验证基础通知链路是否正常：开两个psql会话，第一个会话执行以下命令：

  LISTEN device_snapshot_change;
  

  第二个会话手动发送测试通知：

  SELECT pg_notify('device_snapshot_change', 'test_payload');
  

  如果第一个会话能收到通知，说明PostgreSQL侧的通知链路正常，问题出在Python客户端侧；如果收不到，说明问题出在数据库侧配置。
• 检查通道名大小写匹配问题：PostgreSQL中LISTEN后接的是SQL标识符，未加双引号时会自动转为全小写；而pg_notify的第一个参数是字符串字面量，大小写完全敏感。可通过查询监听列表验证当前连接实际监听的通道：

  -- 在Python代码中执行该语句打印结果，确认两个通道都在监听列表中
  SELECT * FROM pg_listening_channels();
  

• 排查事务提交问题：触发器中RAISE NOTICE会在语句执行时立即返回给当前会话，但pg_notify发送的通知必须等触发更新的事务完全提交后才会推送给监听者。测试时请确认更新操作后已经执行了COMMIT，没有未提交的事务阻塞通知发送。
• 确认连接配置一致：检查Python代码使用的数据库连接，和创建触发器、函数的数据库、schema是否完全一致，避免出现连错测试库/生产库、默认schema不匹配的问题。
• 简化Python代码排除异步逻辑干扰：你当前使用asyncio.add_reader监听同步连接的文件描述符，可能存在偶发的事件循环兼容问题，可以先用同步轮询的最小可复现代码测试：

  import time
  import psycopg2
  
  # 替换为你的连接逻辑
  conn = psycopg2.connect("dbname=your_db user=your_user password=your_pass")
  conn.autocommit = True
  cursor = conn.cursor()
  cursor.execute("LISTEN device_snapshot_change;")
  
  print("开始监听device_snapshot_change通道")
  while True:
      conn.poll()
      while conn.notifies:
          notify = conn.notifies.pop(0)
          print(f"收到通知：通道={notify.channel},  payload={notify.payload}")
      time.sleep(0.5)
  

  如果该代码可以正常收到通知，说明原代码的asyncio事件监听逻辑存在问题。
• 检查通知 payload 长度限制：PostgreSQL的通知payload最大长度为8KB，如果你的device_snapshot字段超过该长度，通知会被丢弃。

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