检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
FunctionGraph（函数计算）参数说明 参数名称 说明 函数 选择需要触发的函数。如果还未创建函数，请先创建函数。 版本/别名 配置版本/别名，当选择其一时，则另外一个参数无需配置。 版本 选择函数的版本。当前默认选择“latest”。 别名 选择函数别名。 执行方式 默认“同步”。
在函数服务的监控中查看代码执行详情 在“函数列表”中找到进行数据同步的函数： 图1 函数列表 单击监控中对应的请求查看代码日志： 图2 代码日志 父主题： 实施步骤
创建FG函数 本章节提供实现图片压缩功能的程序包，使用空白模板创建函数，样例代码请参见使用函数压缩图片。 创建函数（创建函数的时候，必须选择包含OBS访问权限的委托，否则不能使用OBS服务）。 登录函数工作流控制台，在左侧导航栏选择“函数 > 函数列表”，进入函数列表界面。 单击“创建函数”，进入创建函数流程。
左上角单击，搜索“函数工作流”单击进入函数工作流控制台，左侧导航栏选择“函数 > 函数列表”，单击创建好的函数名称进入详情页。 选择“代码”页签，在编辑区增加如下代码，然后单击“部署”刷新代码。 print("body is:", json.dumps(event)) 图2 编辑代码 RocketMQ发布事件至函数工作流
查询单个函数的EG触发器 功能介绍 查询触发器，支持指定函数urn，一个以函数urn为目标的订阅为一个触发器。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET
查询单个函数流的EG触发器 功能介绍 查询触发器，支持指定函数流id，一个以函数流id为目标的订阅为一个触发器。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET
操作流程 前提条件 已开通事件网格服务并授权。 已开通函数服务并授权。 已开通OBS服务并授权。 已在OBS开通白名单（联系OBS服务）。 实践流程 创建事件订阅和事件路由流程如下图所示： 图1 流程图 父主题： 基于EventGrid事件订阅和Function实现OBS桶数据同步
单击“创建函数”，进入“创建空白函数”页面。 参考图3，设置函数参数。关于函数参数的详细介绍，请参考创建函数。 函数类型：选择“事件函数” 区域：选择业务区域 函数名称：输入“test” 委托名称：选择“未使用任何委托” 运行时语言：选择“Python 2.7” 图3 创建函数 单击“创建函数”，完成函数的创建。
主动刷新token，设置事件流状态为ERROR，自动重启事件流。 等待自动恢复。 600 升级中 无动作。 采集函数正在升级，等待升级即可。 403 目标函数被禁用 设置事件流状态为ERROR，上报告警。 检查函数是否正常。 516 topic不存在 检查topic。 510 开启ACL的rocketMq认证失败
事件目标未被触发的原因？ 事件目标未被触发，可能是以下原因导致： 目标函数参数填写错误。 在事件订阅中使用函数工作流中的函数作为事件目标时，检查选择的源、package、函数名是否与预期相符。 事件目标的规则配置错误。 在事件订阅中配置事件目标时，检查选择的转换类型是否与预期相符。
参考图1，设置函数参数。关于函数参数的详细介绍，请参考创建函数。 函数类型：选择“事件函数” 区域：选择业务区域 函数名称：输入“test” 委托名称：选择“未使用任何委托” 运行时语言：选择“Python 2.7” 图1 创建函数 单击“创建函数”，完成函数的创建。 在函数详情页的
API接口为粒度进行权限拆分。 IAM用户授权时请选择“IAM项目视图”方式。 图1 IAM项目视图 如表1所示，包括了事件网格的所有系统权限。 表1 事件网格系统权限 系统角色/策略名称 描述 类别 依赖关系 EG FullAccess 事件网格服务所有权限。 系统策略 无 EG
场景一：函数触发器 事件网格提供了统一的事件源接入方式，为函数工作流服务提供SaaS应用事件或云服务事件的标准化接入。 SaaS应用/云服务将产生的事件发送到事件网格中，事件网格对事件进行校验、过滤、路由和转化，然后推送给已经订阅事件的函数，触发函数执行业务处理逻辑。 图1 函数触发器
单击“下一步”，进入规则配置页面，规则配置可参考过滤规则参数说明。 图2 规则配置 单击“下一步”完成规则配置，您可以参考路由到函数工作流，继续配置事件流的事件目标。 事件源配置为社区版RocketMQ时，配置事件目标为FunctionGraph（函数计算）时，执行方式可选择为“同步”或“异步”。
当数据发送到死信队列后，您可以参考以下方法，来处理死信数据。 登录函数工作流控制台，在左侧的导航栏选择“函数 > 函数列表”。 单击右上方的“创建函数”，进入“创建函数”页面，具体创建步骤请参考创建事件函数。 图2 函数列表 选择创建的函数，单击进入函数详情页。 选择“设置 > 触发器”，单击“创建触发器”，弹出“创建触发器”对话框。
件源”对话框。 在“事件类型”区域，查看事件类型和对应的描述信息，如图2所示。 图1 事件类型 单击操作列“查看示例”，可在弹窗查看示例详情，如果事件有多个示例，弹窗里可以选择要查看的示例。 图2 查看示例 图3 多个示例 父主题： 事件源
8100（从RocketMQ实例的“基本信息”页面的“连接信息”页签中可以获取需要放通的TCP端口。） 图2 RocketMQ入方向规则 配置用户default安全组“出方向规则”。 出方向规则需要放通的协议端口最小集需要包括：ICMP : 全部。 图3 default出方向规则
方案概述 本文介绍如何通过事件网格服务的事件订阅和函数服务实现OBS桶的数据同步。 方案架构 本实践事件订阅架构图如下所示： 图1 事件订阅架构图 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题：
单击“下一步”，进入规则配置页面，规则配置可参考过滤规则参数说明。 图2 规则配置 单击“下一步”完成规则配置，您可以参考路由到函数工作流，继续配置事件流的事件目标。 事件源配置为移动云RocketMQ版时，配置事件目标为FunctionGraph（函数计算）时，执行方式可选择为“同步”或“异步”。
单击“下一步”，进入规则配置页面，规则配置可参考过滤规则参数说明。 图2 规则配置 单击“下一步”完成规则配置，您可以参考路由到函数工作流，继续配置事件流的事件目标。 事件源配置为分布式消息服务RocketMQ版时，配置事件目标为FunctionGraph（函数计算）时，执行方式可选择为“同步”或“异步”。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
