如何使用单个 sqs 为多个表创建外部管道？

Question

我需要使用雪管将数据加载到 2 个表中，即table1,table2

我在 s3 test_snow_pipe_exe bucket table1,table2 子文件夹中有数据，如下路径：

 1) s3://test_snow_pipe_exe/table1/
 2) s3://test_snow_pipe_exe/table2/

所以我通过执行以下代码创建了舞台

create stage test_snow_stage_exe
  storage_integration = test_storageBucket
  url = 's3://test_snow_pipe_exe/'
  file_format = CSV_Format;

现在我想为 2 个表创建 2 个带有单个 sqs 的管道。

如何为 2 个表创建 2 个具有单个 sqs 的管道？

Answer 1

您可以使用相同的 SQS 通知创建 2 个管道，以将数据加载到两个不同的表中。 您还可以让多个管道共享单个阶段，每个管道都写入不同的表，并且只有一个 SQS 通知。