如何调度Snowflake查询生成的CSV文件从Stage传输至FTP服务器？

Snowflake本身没有原生支持直接将Stage文件推送至FTP服务器的功能，你需要通过本地/中间服务器作为中转来实现，以下是具体步骤：

1. 从Snowflake Stage下载文件到本地/中转服务器 #

使用Snowflake的GET命令，将Stage中的文件拉取到本地或中转服务器的指定目录：

GET @your_stage_name/path/to/files/* file:///local/directory/path/;

注意：执行该命令需要使用Snowflake CLI（SnowSQL）或支持Snowflake命令的客户端工具，且运行客户端的机器需要同时能访问Snowflake和目标FTP服务器。

2. 将本地文件上传至FTP服务器 #

可以用脚本语言实现FTP上传，以下是两种常见实现方式：

方式一：Python脚本示例 #

使用ftplib库编写上传逻辑：

from ftplib import FTP

# FTP配置参数
ftp_host = "你的FTP地址"
ftp_user = "你的FTP用户名"
ftp_pass = "你的FTP密码"
local_file_path = "/本地存储目录/目标文件.csv"
remote_file_path = "/FTP远程目录/目标文件.csv"

# 连接FTP并上传
with FTP(ftp_host) as ftp:
    ftp.login(user=ftp_user, passwd=ftp_pass)
    # 切换到目标远程目录（可选）
    ftp.cwd("/FTP远程目录/")
    # 二进制模式上传文件
    with open(local_file_path, 'rb') as f:
        ftp.storbinary(f"STOR {remote_file_path}", f)
    print("文件上传完成")

方式二：Shell脚本示例（Linux/macOS环境） #

安装lftp工具后，编写批量上传脚本：

# 配置参数
FTP_HOST="你的FTP地址"
FTP_USER="你的FTP用户名"
FTP_PASS="你的FTP密码"
LOCAL_DIR="/本地存储目录/"
REMOTE_DIR="/FTP远程目录/"

# 批量上传目录下所有文件
lftp -u $FTP_USER,$FTP_PASS $FTP_HOST << EOF
cd $REMOTE_DIR
mirror -R $LOCAL_DIR
bye
EOF

3. 自动化执行（可选） #

如果需要定期执行传输任务，可以：

• 将SnowSQL的GET命令和FTP上传脚本整合为一个统一脚本
• 使用操作系统定时任务（如Linux的cron、Windows的任务计划程序）定期触发
• 或结合Snowflake任务（Task）与云函数（如AWS Lambda），实现云端自动化触发流程（需确保云函数能访问Snowflake和FTP服务器）

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