Snowflake多表插入是否支持基于字符串列值过滤路由？

这不是Snowflake对字符串列做路由的功能限制，报错核心原因是语法写法错误：
INSERT ALL 语句中 WHEN 分支的判断条件，只能引用后续子查询SELECT列表中返回的列。你之前写CITY='ny'判断逻辑的版本里，子查询只查了CUSTID,LASTNAME,FIRSTNAME,ADDRESS四个字段，没有返回CITY列，自然会报invalid identifier 'CITY'的错误。
你换成CUSTID做判断能执行成功，和CUSTID是数值类型没有任何关系，纯粹是因为CUSTID在子查询的SELECT返回列表里，能被WHEN子句正常引用。

方案1：修正多表INSERT语句（最小改动） #

只需要在子查询的SELECT列表中补上CITY列即可，不需要把CITY写入目标表，WHEN条件判断完路由规则后，INTO子句只取目标表需要的字段就行，修正后的代码如下：

INSERT ALL
WHEN CITY='ny' THEN
    INTO NYCUST(CUSTID,LASTNAME,FIRSTNAME,ADDRESS) VALUES(CUSTID,LASTNAME,FIRSTNAME,ADDRESS)
WHEN CITY='blr' THEN
    INTO BLRCUST(CUSTID,LASTNAME,FIRSTNAME,ADDRESS) VALUES(CUSTID,LASTNAME,FIRSTNAME,ADDRESS)
-- 子查询补上路由判断需要的CITY列
SELECT CUSTID,LASTNAME,FIRSTNAME,ADDRESS, CITY 
FROM CUST_STREAM 
WHERE metadata$action ='INSERT';

执行后Stream的消费偏移量会正常推进，和你之前用CUSTID路由的行为完全一致。如果需要兜底处理不匹配任何规则的脏数据，可以在最后加ELSE INTO 异常表名 VALUES(...)分支，避免数据丢失。如果需要一条数据只命中第一个匹配的分支、不重复写入多表，可以把INSERT ALL替换为INSERT FIRST。

方案2：动态表自动路由（运维成本最低，适配Kafka持续写入场景） #

如果路由规则是固定的按列值过滤，不需要复杂分支逻辑，可以直接给每个目标表创建动态表，自动从源表增量消费对应规则的数据，不需要手动写INSERT调度逻辑，也不需要自己维护Stream消费进度，示例：

-- 纽约客户表自动同步
CREATE OR REPLACE DYNAMIC TABLE NYCUST
TARGET_LAG = '1 minute' -- 根据业务对数据延迟的要求配置
WAREHOUSE = 你的计算仓库名
AS
SELECT CustId,LastName,FirstName,Address
FROM CUSTOMERS
WHERE City = 'ny';

-- 班加罗尔客户表自动同步
CREATE OR REPLACE DYNAMIC TABLE BLRCUST
TARGET_LAG = '1 minute'
WAREHOUSE = 你的计算仓库名
AS
SELECT CustId,LastName,FirstName,Address
FROM CUSTOMERS
WHERE City = 'blr';

这种方案下Kafka Connect写入CUSTOMERS表的增量数据，会按照设置的target_lag自动同步到对应目标表，适配持续入仓的流式场景。

方案3：Task+存储过程（适配复杂路由逻辑） #

如果后续路由规则会扩展（比如多条件组合判断、匹配不到的数据写入异常表、路由前需要做复杂数据清洗转换），可以创建挂载在CUST_STREAM上的定时Task，触发时调用存储过程消费Stream数据，在存储过程里实现分支路由、异常告警、数据校验等复杂逻辑，适合生产环境高要求场景。

内容的提问来源于stack exchange，提问作者Colin D'souza