如何将SNOWPIPE从一个schema迁移到另一个schema？

核心问题解答 #

当前Snowflake没有提供ALTER PIPE修改所属schema、跨schema重命名移动管道的语法。
你提到的CREATE OR REPLACE PIPE <target_schema>.<mypipe_name> AS ...命令不会替换源schema下的原有管道，它仅作用于你指定的目标schema：如果目标schema下没有同名pipe就新建，存在就覆盖目标schema下的该pipe，源schema的原pipe会完整保留不受影响。

完整迁移步骤 #

• 先暂停源schema的原有管道，避免迁移期间出现重复加载
  执行命令：ALTER PIPE <source_schema>.<mypipe_name> SET PIPE_EXECUTION_PAUSED = true;
• 确认源管道的待加载文件全部处理完成，避免数据遗漏
  执行命令查询队列状态：SELECT SYSTEM$PIPE_STATUS('<source_schema>.<mypipe_name>');
  确认返回结果中pendingFileCount参数值为0后再继续操作
• 查询源管道的完整DDL定义，避免手动写错配置
  执行命令：SELECT GET_DDL('PIPE', '<source_schema>.<mypipe_name>');
• 替换DDL中的schema为目标schema，执行创建语句生成新管道
  示例命令：

  CREATE OR REPLACE PIPE <target_schema>.<mypipe_name>
  AUTO_INGEST = [原管道的自动摄取开关值]
  INTEGRATION = '<原管道绑定的集成名称>' -- 配置了通知集成的管道需要保留该参数
  AS
  -- 粘贴原管道COPY INTO的完整逻辑
  

• 验证目标管道的权限配置：确保管道所属角色拥有目标schema、目标表的读写权限，以及对应对象存储的访问权限
• 如果你用的是自动摄取管道，需要更新对应存储桶的事件通知配置，将触发目标替换为新管道的通知端点，可通过以下命令查询新管道的端点：
  执行命令：SELECT SYSTEM$PIPE_STATUS('<target_schema>.<mypipe_name>');
  提取返回结果中的notificationChannelName字段值更新存储事件配置即可
• 验证新管道数据加载正常后，按需删除源schema的旧管道：
  执行命令：DROP PIPE <source_schema>.<mypipe_name>;

注意事项 #

迁移期间可以先不删除源管道，保持暂停状态运行1-2天，确认新管道完全稳定后再执行删除操作
如果你开启了管道的时间旅行功能，删除前确认没有需要回溯的加载历史再操作

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