事件网格 EG-华为云

事件网格 EG-死信队列:操作步骤

操作步骤登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击“创建事件订阅”。单击“事件目标”。在弹窗中选择“事件目标”。启用“死信队列”，并配置参数。图1 配置死信队列表1 死信队列参数说明参数名称说明队列类型选择队列类型。实例选择实例。目标连接选择目标连接。说明：目前只能选择与队列类型匹配的目标连接。 Topic 选择Topic。说明：如果事件目标与死信队列使用同一个Topic，EG将无法区分事件成功与失败，不推荐您配置同一个Topic。单击“确定”，完成死信配置。

事件网格 EG

事件网格 EG-编辑事件订阅:修改事件源

修改事件源登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击待修改事件源参数的订阅名称，进入订阅详情页。单击已有事件源模块，弹出“事件源”对话框。修改事件源配置参数。已创建的订阅，无法修改事件源提供方。当提供方为“云服务”时，设置如表1所示参数。表1 云服务事件源参数说明参数名称说明事件源选择云服务事件源。事件类型（可选）选择事件网格预定义的事件类型。过滤规则输入事件过滤规则。事件源产生的事件与过滤规则进行匹配，匹配成功后事件才会被路由到与过滤规则关联的事件目标。如果需要了解更多过滤规则的信息，请参考过滤规则参数说明和过滤规则示例。图1 云服务事件源配置参数当提供方为“自定义”时，设置如表2所示参数。已创建的订阅，无法修改已绑定的自定义事件通道。表2 自定义事件源参数说明参数名称说明通道在下拉列表中选择一个已创建的自定义事件通道，例如：channel。事件源输入或选择一个已关联自定义事件通道（即“通道配置”中选择的自定义通道，例如：channel）的自定义事件源。过滤规则输入事件过滤规则。事件源产生的事件与过滤规则进行匹配，匹配成功后事件才会被路由到与过滤规则关联的事件目标。如果需要了解更多过滤规则的信息，请参考过滤规则参数说明和过滤规则示例。图2 自定义事件源参数配置单击“确定”。单击“保存”，完成事件源的修改。

事件网格 EG 事件订阅

事件网格 EG-创建OBS源桶和目标桶

创建OBS源桶和目标桶登录OBS控制台。单击“创建桶”，进入“创建桶”页面。设置桶参数。关于桶参数的详细介绍，请参考创建桶。表1 桶参数配置参数说明区域事件网格与所在区域保持一致。桶名称输入示例如“eg-test”。默认存储类别按需选择。桶策略按需选择。默认加密按需选择。归档数据直读按需选择。企业项目按需选择。图1 桶参数配置配置完成后，单击“立即创建”，根据提示信息完成桶的创建。以上述流程构建源桶与目标桶。父主题：实施步骤

事件网格 EG 实施步骤

事件网格 EG-跨账号事件发送流程:步骤四：在账号B中创建订阅去处理目标通道的事件

步骤四：在账号B中创建订阅去处理目标通道的事件登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击“创建事件订阅”。单击“事件源”，在配置弹窗进行配置，配置完成单击“确定”。提供方选择“自定义”。通道：选择账号B创建的通道。事件源：输入账号A创建的事件源（与账号A的订阅的事件源保持一致）。图5 事件源配置单击“事件目标”，在配置弹窗进行配置，配置完成单击“确定”（此处目标以函数为例）。提供方选择“华为云”。事件目标：选择FunctionGraph（函数计算）。函数：选择函数。版本：选择版本。委托：选择委托。类型：选择透传、变量或常量。图6 事件目标配置图7 生成的订阅全量配置方式可参考《创建事件订阅》。进入目标通道的事件轨迹页面，查看投递状态。图8 投递状态投递状态显示“投递成功”，跨账号事件发送成功。

事件网格 EG

事件网格 EG-跨账号事件发送流程:步骤二：在账号A下创建事件订阅

步骤二：在账号A下创建事件订阅登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击“创建事件订阅”。单击“事件源”，在配置弹窗进行配置，配置完成单击“确定”。提供方选择“华为云”。事件源：选择消息通知 SMN。单击“事件目标”，在配置弹窗进行配置，配置完成单击“确定”。提供方选择“华为云”。事件目标：选择事件网格EG。目标类型：选择跨账号。项目ID：项目ID填写账号B同地域下的项目ID。通道：选择账号B创建的通道。委托：选择带有事件发送权限的委托。图2 配置事件目标创建成功后，单击“保存”。

事件网格 EG

事件网格 EG-跨账号事件发送流程:步骤三：发送SMN事件验证

步骤三：发送 SMN 事件验证登录消息通知服务SMN控制台。在左侧导航栏选择“主题管理”，进入“主题”页面。单击“创建主题”。输入“主题名称”，选择“企业项目”后单击“确定”。登录事件网格控制台。在左侧导航栏选择“事件通道”，进入“事件通道”页面。单击default通道后的“事件轨迹”。图3 事件轨迹进入事件轨迹页面，单击对应事件操作列的“事件轨迹”。图4 投递详情查看事件轨迹投递详情显示成功。

事件网格 EG

事件网格 EG-华为云服务事件发送流程:步骤三：产生OBS事件（创建OBS桶）

步骤三：产生OBS事件（创建OBS桶）登录OBS控制台。单击“创建桶”，进入“创建桶”页面。参考图4，设置桶参数。关于桶参数的详细介绍，请参考创建桶。区域：与事件网格所在区域保持一致桶名称：输入“eg-test” 默认存储类别：选择“标准存储” 桶策略：选择“私有” 默认加密：不勾选归档数据直读：选择“关闭” 企业项目：选择“default” 图4 创建桶单击“立刻创建”，根据提示信息完成桶的创建。

事件网格 EG

事件网格 EG-华为云服务事件发送流程:步骤二：创建事件订阅

步骤二：创建事件订阅事件订阅将事件源、通道和事件目标绑定在一起，通过事件规则将事件源发出的事件路由到事件目标。登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击“创建事件订阅”，进入订阅详情页。单击订阅名称旁的，弹出“修改订阅”弹窗。在“订阅名称”中输入“OfficialEvent”，单击“确定”，回到订阅详情页。配置事件源。单击“事件源”，参考图2，设置事件源参数。选择提供方：选择“华为云” 事件源：选择“ 对象存储服务 ” 过滤规则：保存默认图2 设置事件源参数单击“确定”，完成事件源的配置。配置事件目标。单击“事件目标”，参考图3，设置事件目标参数。选择提供方：选择“华为云” 事件目标：选择“FunctionGraph（函数计算）” 函数：选择步骤一中创建的“test”函数版本：选择“latest” 类型：选择“透传” 图3 设置事件目标参数单击“确定”，完成事件目标的配置。单击“保存”，完成事件订阅的配置。

事件网格 EG

事件网格 EG-自定义事件发送流程:步骤二：创建自定义事件源

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

事件网格 EG

事件网格 EG-自定义事件发送流程:步骤五：发送自定义事件

步骤五：发送自定义事件配置自定义事件，具体请参考CloudEvents SDK。修改发布事件示例代码中如下参数： NAME： IAM 用户名。 PASSWORD：IAM 用户密码。 DOMAIN_NAME：IAM domain用户名。 IAM_ENDPOINT：IAM的终端节点，您可以从地区和终端节点中查询服务的终端节点。 PROJECT_ID：即项目ID，参考API凭证，获取项目ID。 CHANNEL_ID：修改为步骤一中记录的通道ID。 ENDPOINT：事件网格访问端点，如“华北-北京四”区域，公网访问端点值为“events.cn-north-4.myhuaweicloud.com”。 SOURCE：即事件源名称，修改为步骤四中配置事件源时记录的“Filter”中“values”值。 TIME：修改事件产生的时间。 DATA：根据实际情况修改，事件内容遵循CloudEvents 1.0规范。运行发布事件的main函数。

事件网格 EG

事件网格 EG-授权委托:委托场景

委托场景首次创建目标连接时，系统会自动弹出创建委托授权界面，同意授权后，EG将在统一身份认证服务为您创建名为EG_DELEGATE_FG_AGENCY的委托。授权成功后，您可以在IAM控制台的委托列表中查看已创建的委托。表2 EG_DELEGATE_FG_AGENCY的委托权限权限名称描述 VPC Administrator 目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。首次创建自定义事件源“事件源类型”选择“分布式消息服务RabbitMQ版”或“分布式消息服务RocketMQ版”时，系统会自动弹出创建委托授权界面，同意授权后，EG将在统一身份认证服务为您创建名为EG_DELEGATE_FG_AGENCY和EG_AGENCY的委托。授权成功后，您可以在IAM控制台的委托列表中查看已创建的委托。表3 EG_DELEGATE_FG_AGENCY和EG_AGENCY的委托权限权限名称描述 VPC Administrator 自定义分布式消息服务事件源功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 自定义分布式消息服务事件源功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。 EG Publisher 自定义分布式消息服务事件源功能需要将消费到的消息发布事件到事件通道，需要用户必须为事件网格服务配置具备事件发布权限的委托。

事件网格 EG

事件网格 EG-Kafka同步Kafka:操作步骤

操作步骤登录事件网格控制台。在左侧导航栏选择“事件流＞专享版事件流作业”，进入“专享版事件流作业”页面。图1 专享版事件流作业页面右上角单击“创建作业”，进入“基础配置”。配置“基本配置”信息。图2 基本配置表1 作业基本配置参数说明参数说明集群选择已创建的集群，如未创建，请参见专享版事件流集群。作业名称请输入作业名称。场景类型当前默认为同步。描述请输入对本作业的描述。单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。 “源数据”和“目标数据”中选择好Kafka实例后，单击“测试连通性”，检查通过后，进入步骤6。图3 源数据和目标数据配置表2 源数据和目标数据配置参数说明参数说明配置类型默认为“Kafka实例”。说明：配置类型根据实例类型变更。实例别名请输入实例别名。说明：用于标识源端和目标端实例，建议同一个源端或目标端实例只设置一个别名。区域请选择资源所在区域。项目请选择项目。 Kafka实例请选择Kafka实例。接入方式支持“明文接入”或“密文接入”。安全协议当选择明文接入时，安全协议为“PLAINTEXT”。当选择“密文接入”时，安全协议可选择“SASL_SSL”或“SASL_PLAINTEXT”；认证机制可选择“SC RAM -SHA-512”或“PLAIN”。用户名请输入用户名。说明：当接入方式选择“密文接入”时需配置。密码请输入密码。说明：当接入方式选择“密文接入”时需配置。单击“下一步：高级配置”，进入“高级配置”页面。图4 高级配置表3 作业对象配置参数说明参数说明 Topic匹配类型选择“正则匹配”或“精确匹配”。说明：当选择“正则匹配”时需在下方输入“Topic正则”。示例：.* 表示匹配所有Topic，topic.* 表示匹配所有以topic为前缀的Topic。当选择“精确匹配”时需选择“Topics”。副本数请配置副本数。说明：自动创建的Topic副本数，不能超过目标端Kafka的Broker数量。同步消费进度请选择是否打开。说明：开启时表示将消息消费进度同步到目标Kafka。启动偏移量请选择为“最早”或“最新”。压缩算法请选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。单击“下一步：预检查”，进入“预检查”页面，完成后单击“完成配置”。图5 预检查返回专享版事件流作业列表，单击刚才创建的事件流名称，进入“基本信息”页面，选择“作业管理”，可以查看“同步进展详情”。图6 Kafka事件流同步进展详情表4 参数说明参数名称说明 Topic名称创建Kafka实例时的Topic。分区数创建Topic时设置的分区数，分区数越大消费的并发度越大。待同步数当前Topic分区数中未同步的消息数量。同步速率：当前作业同步消息时的速率，单击“限流”可跳转至源端Kafka实例的“流控列表”页面，用户可通过配置流控进而实现限流目的。

事件网格 EG

事件网格 EG-专享版事件流预检查

专享版事件流预检查当前仅支持华南-广州。预检查是创建事件流作业流程中的一环，用来检查用户填写的配置信息是否符合要求。预检查包含多个检查项，详情请参考表1，且每项检查独立执行，检查结果分成功、失败和告警三种类型。表1 检查项目介绍项目内容源端和目标端实例版本检查检查源端实例和目标端实例的版本是否匹配。源端连通性检查检查作业所在运行时机器是否能正常连接到源端实例。目标端连通性检查检查作业所在运行时机器是否能正常连接到目标端实例。源端和目标端实例规格检查检查源端实例和目标端实例的规格是否匹配。对于预检查结果是告警或者失败的事件流作业，都不会阻塞事件流作业的创建流程，检查结果仅做提示用。 Kafka预检查 RocketMQ预检查父主题：专享版事件流

事件网格 EG

事件网格 EG-Kafka预检查:目标端连通性检查

目标端连通性检查检查事件流作业所在运行时机器是否能正常连接到目标端Kafka实例。原因一：无法连接目标端Kafka实例，请检查网络配置是否正确。解决方案：进入Kafka的控制台页面，检查目标端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与目标端Kafka实例网络畅通。原因二：无法连接目标端Kafka实例，请检查填写的实例信息是否正确。解决方案：进入Kafka的控制台页面，检查目标端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与目标端Kafka实例网络畅通。检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的目标端Kafka实例的用户名和密码是否正确。

事件网格 EG

事件网格 EG-Kafka预检查:源端和目标端实例版本检查

源端和目标端实例版本检查检查源端和目标端实例的版本是否符合要求，当前要求Kafka实例版本在 3.x和2.7 中，版本不在匹配名单中则提示告警。原因一：源端Kafka实例版本不支持，请选择符合要求的实例。解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为源端实例。原因二：目标端Kafka实例版本不支持，请选择符合要求的实例。解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。检查源端和目标端Kafka实例的版本是否一致，版本不一致则提示告警。原因：源端实例和目标端实例的版本不一致，请检查源端实例和目标端实例的版本。解决方式：检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中源端和目标端Kafka实例版本是否一致，若不一致，请修改源端或者目标端实例，使二者保持一致。否则，版本不一致可能会存在兼容性和性能风险。

事件网格 EG

云服务器内容精选

事件网格 EG

7*24

备案

专业服务

退订

建议反馈

售前咨询热线