指向Azure Blob的Snowflake外部表

问题描述

我已经创建了一个指向Azure Blob的外部表,但其中没有任何数据。

我已经在外部表中使用了通知集成来创建SNowpipe,并且使用SNowpipe将数据加载到表中。

注意:Azure端的所有配置都已完成

我的代码

create notification integration MY_AZURE_INT1
  enabled = true
  type = queue
  notification_provider = azure_storage_queue
  azure_storage_queue_primary_uri = 'https://xxxhhhhhdfdfdgdh'
  azure_tenant_id = '093715bd-960e-470c-b5b9-4981d133361c'

创建通知

CREATE OR REPLACE STAGE AZURE_STAGE
  url = 'azure://sNowpipedatastorage342345.blob.core.windows.net/sNowpipe-source-blob'
  credentials = (azure_sas_token=
    '?sp=rl&st=2020-09-17T12:15:20Z&se=2020-10-18T12:15:00Z&sv=2019-12-12&sr=c&sig=gnCc%2FfGk8005pBXNe2DMSeZIPqZy2GE4NsbereghhDwyE%3D
');

创建阶段

create or replace external table ext_table
 integration = 'MY_AZURE_INT1'
 with location = @AZURE_STAGE/call_center
    file_format = (format_name = CSV_FORMAT)
    auto_refresh = true
    REFRESH_ON_CREATE = TRUE 

雪管

create or replace pipe spipe1
  auto_ingest = true
  integration = 'MY_AZURE_INT1'
  as
  copy into call_center
  from @AZURE_STAGE/call_center
    file_format = (format_name = CSV_FORMAT)
    pattern='.*[.]csv';

正在使用SNowpipe加载数据,而使用外部表则没有数据加载

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)