【发布时间】:2020-01-18 01:41:02
【问题描述】:
我正在尝试建立一个 Snowpipe,我已经创建了我的仓库、数据库和表,并正在尝试使用 snowsql 暂存文件。
USE WAREHOUSE IoT;
USE DATABASE SNOWPIPE_TEST;
CREATE OR REPLACE STAGE my_stage;
CREATE OR REPLACE FILE_FORMAT r_json;
CREATE OR REPLACE PIPE snowpipe_pipe
AUTO_INGEST = TRUE,
COMMENT = 'add items IoT',
VALIDATION_MODE = RETURN_ALL_ERRORS
AS (COPY INTO snowpipe_test.public.mytable
from @snowpipe_db.public.my_stage
FILE_FORMAT = (type = 'JSON');
CREATE PIPE mypipe AS COPY INTO mytable FROM @my_stage;
我尝试将配置文件保存为 config1 并制作了一份副本。它挂了,然后我删除了副本并尝试连接,没有错误,它只是挂了
我错过了什么吗?
【问题讨论】:
-
您想要使用雪管,还是只加载一些数据?我问是因为你在这里配置一个内部阶段。如果您只想从内部阶段加载一些文件,请使用 COPY,不使用雪管。
-
我确实想使用 Snowpipe。
标签: snowflake-cloud-data-platform