管理消费处理器

在对Logstore进行实时消费时,使用消费处理器可以对数据进行数据变换操作,例如数据过滤、字段提取、字段扩展、数据脱敏等场景。本文介绍如何在日志服务控制台上管理消费处理器。

创建消费处理器

控制台

  1. 登录日志服务控制台。在Project列表区域,单击目标Project。

    image

  2. 在左侧导航栏,选择资源 > 数据处理器。在数据处理器页面中,单击消费处理器

    image

  3. 消费处理器页签中,单击创建。在创建处理器面板配置处理器名称描述SPL,配置完成后单击保存。参数说明如下。

    参数

    说明

    处理器名称

    消费处理器的名称。

    描述

    消费处理器的描述。

    SPL

    SPL语句。关于SPL语法,更多信息,请参见SPL语法

API

PutConsumeProcessor - 创建或修改消费处理器

删除或修改消费处理器

如果消费处理器被删除,使用消费处理器的程序如Flink、Dataworks、 SDK等会出现持续报错,停止消费数据。建议在停止消费程序后,删除消费处理器。

控制台

数据处理器 > 消费处理器页签,查看已创建的处理器列表,您可以单击修改或者删除对目标消费处理器进行管理。

image

API

后续步骤