创建流数据处理任务

使用EnOS流数据处理服务提供的算法模板和StreamSets算子库,可快速创建流数据处理任务。创建任务可通过新建或者导入现有配置两种方式来完成。

前提条件

  • 已被授权访问流数据处理服务

  • 组织已申请流数据处理资源

  • 已安装需要的算法模板和算子库

新建任务

新建流数据处理任务的步骤如下:

  1. 登录EnOS管理门户,点击 流数据处理 > 流开发,点击任务列表上方的 + 图标。

  2. 添加流 窗口中,选择 新建 方式。

  3. 输入流数据处理任务的名称和描述。

  4. 模板 下拉菜单中,选择对应的流数据处理模板;从 版本 下拉菜单中,选择对应的版本号。

  5. 数据通道 栏中,选择待处理的流数据类型:

    • 若数据为接入设备上送的数据,选择 实时通道

    • 若数据为通过消息集成模块导入的数据,选择 离线通道

  6. 点击 确认,进入数据处理策略配置页面。

../../_images/create_stream.png

导入配置

通过导入现有流数据处理任务的配置文件,可快速创建流数据处理任务,具体步骤如下:

  1. 登录EnOS管理门户,点击 流数据处理 > 流开发,点击任务列表上方的 + 图标。

  2. 添加流 窗口中,选择 导入配置 方式。

  3. 输入流数据处理任务的名称和描述。

  4. 点击 选择文件,选择并上传已导出的流数据处理任务配置文件。任务的模板和版本信息将被自动导入。

  5. 数据通道 栏中,选择待处理的流数据类型:

    • 若数据为接入设备上送的数据,选择 实时通道

    • 若数据为通过消息集成模块导入的数据,选择 离线通道

  6. 点击 确认,进入数据处理策略配置页面,并编辑导入的数据处理等配置信息,完成流数据处理任务的创建。

../../_images/import_stream_config.png