使用SLS SPL需要完成以下准备工作。首先需要开通日志服务SLS,在SLS中创建Project和Logstore,并确保Logstore中已有数据接入。其次需要创建具有消费Logstore权限的账号AK/SK,用于Flink Connector的身份认证。然后在阿里云Flink控制台创建SQL流作业草稿,在CREATE TEMPORARY TABLE语句中配置Connector参数。关键参数包括:endpoint填写同地域的SLS私网地址、accessId和accessKey填写授权账号、project和logstore指定数据源、starttime指定消费起始时间、query参数填写SPL语句。配置完成后可以通过Flink控制台的调试功能验证SPL过滤效果。




