能否在同一会话中为Citus分布式表创建并配置触发器？

Citus原生不支持直接给分布式表创建触发器，官方给出的替代方案步骤如下：

• 创建不带触发器的普通表
• 编写触发器执行函数
• 调用run_command_on_shards函数，为每个分片单独创建触发器

对应的示例代码：

drop table if exists events;

CREATE TABLE events (
  id bigserial PRIMARY KEY,
  description text NOT NULL,
  author name NOT NULL
);

SELECT create_distributed_table('events', 'id');

-- 创建触发器执行函数
CREATE OR REPLACE FUNCTION set_author() RETURNS TRIGGER AS $$
  BEGIN
    NEW.author := current_user;
    RETURN NEW;
  END;
$$ LANGUAGE plpgsql;

-- 为每个分片创建触发器
SELECT run_command_on_shards(
  'events',
  $cmd$
    CREATE TRIGGER events_set_author BEFORE INSERT OR UPDATE ON %s
      FOR EACH ROW EXECUTE PROCEDURE set_author()
  $cmd$
);

问题现象 #

如果在单个事务中执行上述全部代码，会触发类似relation ""events_153432"" does not exist的错误（数字为分片表的随机后缀）；但分两次执行——先完成表创建与分布式处理并提交事务，再执行触发器创建逻辑——就能正常运行。

原因分析 #

你的两个推测都准确命中了核心原因，具体细节如下：

1. 事务隔离导致分片表不可见
   PostgreSQL的事务隔离机制下，节点间的事务状态相互隔离。在单个事务中执行create_distributed_table时，协调节点虽已更新分布式元数据，但worker节点上的分片表创建操作处于同一事务上下文，事务未提交前，这些分片表对run_command_on_shards发起的独立查询不可见——因为run_command_on_shards会在worker节点上单独执行命令，无法共享协调节点的事务快照。

2. create_distributed_table的异步执行特性
   create_distributed_table函数本身是同步返回的，但它触发的worker节点分片表创建操作，是通过Citus的任务调度框架异步执行的。函数返回时，协调节点的元数据已更新，但worker节点上的分片表可能还未完成创建，此时调用run_command_on_shards自然找不到对应的分片表。

解决方法 #

• 拆分事务：将表创建、分布式处理的逻辑放在一个事务中执行并提交，之后再单独执行触发器创建的逻辑，这是最稳妥的生产环境方案。
• 测试场景下，可在create_distributed_table后添加轮询逻辑，确认所有worker节点的分片表都已创建完成，再执行run_command_on_shards。

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