在阿里云Flink的SLS Connector中配置SPL行过滤,需要在CREATE TEMPORARY TABLE语句的WITH参数中设置query字段。例如要过滤slbid为slb-01的数据,可以设置'query' = '* | where slbid = ''slb-01'''。需要特别注意的是,在阿里云Flink的SQL作业开发中,字符串值需要使用两个英文单引号进行转义。配置完成后,SLS服务端会在数据发送到Flink之前执行过滤操作,只将满足条件的数据传输给Flink。这样可以大幅减少Flink对SLS的读流量,同时在过滤占比较高的场景下,Flink CU消耗也会相应降低。




