如何在Snowflake Stage中重命名文件？无需本地下载上传

问题原因说明 #

你使用COPY FILES时生成拼接文件名，是因为Snowflake会将INTO后的路径视为前缀而非目标文件名，直接将源文件名追加到该前缀后，导致出现new_filenamecurrent_filename这类结果。COPY FILES本身不支持直接重命名单个文件，以下是无需下载到本地的替代方案：

方案一：临时表中转（适用于结构化数据） #

如果你的文件是CSV、JSON等结构化数据，可以通过临时表中转实现重命名：

1. 将源文件数据导入临时表：

   CREATE OR REPLACE TEMPORARY TABLE temp_file_data AS
   SELECT $1 FROM @mystage/current_filename;
   

2. 将临时表数据导出到Stage的新文件：

   COPY INTO @mystage/new_filename
   FROM temp_file_data
   FILE_FORMAT = (TYPE = CSV); -- 根据你的文件格式调整，比如JSON、PARQUET等
   

3. 删除原文件：

   REMOVE @mystage/current_filename;
   

方案二：存储过程操作（适用于非结构化/二进制文件） #

如果是图片、PDF等非结构化文件，可以通过存储过程读取文件内容后写入新文件：

1. 创建重命名存储过程：

   CREATE OR REPLACE PROCEDURE rename_stage_file(stage_name VARCHAR, old_filename VARCHAR, new_filename VARCHAR)
   RETURNS VARCHAR
   LANGUAGE JAVASCRIPT
   AS
   $$
   // 读取原文件二进制内容
   const getContentStmt = snowflake.execute({
       sqlText: `SELECT GET_FILE_CONTENTS(@:1, :2)`,
       binds: [STAGE_NAME, OLD_FILENAME]
   });
   getContentStmt.next();
   const fileContent = getContentStmt.getColumnValue(1);
   
   // 将内容写入新文件（关闭自动压缩避免格式损坏）
   snowflake.execute({
       sqlText: `PUT 'data://' || :1 @:2/:3 AUTO_COMPRESS=FALSE`,
       binds: [fileContent, STAGE_NAME, NEW_FILENAME]
   });
   
   // 删除原文件
   snowflake.execute({
       sqlText: `REMOVE @:1/:2`,
       binds: [STAGE_NAME, OLD_FILENAME]
   });
   
   return "文件重命名完成";
   $$;
   

2. 调用存储过程执行重命名：

   CALL rename_stage_file('mystage', 'current_filename', 'new_filename');
   

方案三：外部Stage云存储API操作（如果使用云存储外部Stage） #

如果你的Stage是基于S3、Azure Blob、GCS等云存储的外部Stage，可以直接调用对应云服务商的API完成文件重命名：

• AWS S3：使用CopyObject接口复制原文件到新路径，再调用DeleteObject删除原文件
• Azure Blob：使用RenameBlob接口直接重命名
• GCS：使用rewrite接口复制原文件到新路径，再删除原文件
  这种方式无需经过Snowflake中转，效率更高。

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