有一个要求，我需要从Snowflake复制CDC数据，而不使用Stream。
我选择了CHANGES子句，通过Alter表使用，并能够在Snowflake中获取更改数据，并添加3个元数据列：但与我使用Pipeline从Azure Copy Activity阅读查询复制Activity的方式相同，但我无法复制数据。

积分：
1.查找读取所有表列表

1. For Each活动迭代每个表并执行其他操作
   1.对于每个表，我都执行一个脚本，该脚本捕获时间并基于时间进行提取。4、复制数据
   我正在使用的查询：

SET ts1 = (SELECT LASTRUNTIME as Time FROM CDC_TABLE);
SELECT *,$ts1 as Time FROM CDC_TABLE;

 -- change data with all meta data.
SELECT * FROM AGENTS CHANGES(INFORMATION => DEFAULT)  AT (timestamp => $ts1 )  ORDER BY 'AGENT_CODE';

-- change data excluding meta data.
SELECT *  
EXCLUDE (METADATA$ACTION, METADATA$ISUPDATE, METADATA$ROW_ID)
,CASE WHEN METADATA$ACTION = 'INSERT' AND METADATA$ISUPDATE = 'TRUE' THEN 'U'
              WHEN METADATA$ACTION = 'INSERT' AND METADATA$ISUPDATE = 'FALSE' THEN 'I'
              ELSE 'D'
         END AS CHANGE_OPERATION
FROM (SELECT * FROM AGENTS   CHANGES(INFORMATION => DEFAULT) AT (timestamp => $ts1 ) )
WHERE  METADATA$ACTION != 'DELETE';                                                             

  
  UPDATE CDC_TABLE 
  SET PREVIOUS_RUNTIME = LASTRUNTIME, LASTRUNTIME = CURRENT_TIMESTAMP
  WHERE TABLE_NAME = 'AGENTS';

上述查询在复制数据活动中不起作用，显示以下错误：

请在这件事上帮助我。寻求Maven的建议。