自定义事件发送流程

本章节介绍自定义事件发送的整个流程。

将自定义事件源产生的自定义事件发送到事件网格，事件规则对自定义事件进行过滤和转换，通过转换后的事件触发事件目标（即函数工作流服务中的函数）。

前提条件

已开通事件网格服务并授权。
已获取函数工作流的权限。

步骤一：创建自定义通道

登录事件网格控制台。
在左侧导航栏选择“事件通道”，进入“事件通道”页面。
单击“创建事件通道”，弹出“创建事件通道”对话框。
在“通道名称”中输入“channel”，单击“确定”，完成自定义事件通道的创建。

通道创建成功后，在“自定义事件通道”区域查看创建的自定义事件通道，并记录事件通道ID。

图1 事件通道ID

步骤二：创建自定义事件源

登录事件网格控制台。
在左侧导航栏选择“事件源”，进入“事件源”页面。
单击“自定义事件源”，弹出“创建自定义事件源”对话框。
参考图2，填写自定义事件源的配置信息。
- 配置类型：选择“选择”
- 通道：选择步骤一创建的“channel”通道
- 事件源名称：输入“egsdk-source”
图2 创建自定义事件源
单击“确定”，完成自定义事件源的创建。

创建成功后，在“自定义事件源”页签，查看创建的事件源。

步骤三：创建云服务事件目标（创建函数）

登录函数工作流控制台。
在左侧导航栏选择“函数 > 函数列表”，进入函数列表页面。
单击“创建函数”，进入“创建空白函数”页面。
参考图3，设置函数参数。关于函数参数的详细介绍，请参考创建函数。
- 函数类型：选择“事件函数”
- 区域：选择业务区域
- 函数名称：输入“test”
- 委托名称：选择“未使用任何委托”
- 运行时语言：选择“Python 2.7”
图3 创建函数
单击“创建函数”，完成函数的创建。

在函数详情页的“代码”页签中，输入如下代码，单击“部署”。

# -*- coding:utf-8 -*-
import json
def handler (event, context):
    print(json.dumps(event))
    return {
        "statusCode": 200,
        "isBase64Encoded": False,
        "body": json.dumps(event),
        "headers": {
            "Content-Type": "application/json"
        }
    }

步骤四：创建事件订阅

事件订阅将事件源、通道和事件目标绑定在一起，通过事件规则将事件源发出的事件路由到事件目标。

登录事件网格控制台。
在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。
单击“创建事件订阅”，进入订阅详情页。
单击订阅名称旁的，弹出“修改订阅”弹窗。
在“订阅名称”中输入“CustomEvent”，单击“确定”，回到订阅详情页。
配置事件源。
1. 单击“事件源”，参考图4，设置事件源参数。
  - 选择提供方：选择“自定义”
  - 通道配置 > 配置类型：选择“选择”
  - 通道配置 > 通道：选择步骤一创建的“channel”通道
  - 事件源配置 > 配置类型：选择“选择”
  - 事件源配置 > 事件源：选择步骤二创建的“egsdk-source”
  - 过滤规则：保存默认，并记录values值，如图4所示的“egsdk-source”。
  图4 配置事件源参数
2. 单击“确定”，完成事件源的配置。
配置事件目标。
1. 单击“事件目标”，参考图5，设置事件目标参数。
  - 选择提供方：选择“华为云”
  - 事件目标：选择“FunctionGraph（函数计算）”
  - 函数：选择步骤三中创建的“test”函数
  - 版本：选择“latest”
  - 类型：选择“透传”
  图5 配置事件目标参数
2. 单击“确定”，完成事件目标的配置。
单击“保存”，完成事件订阅的配置。