检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
更新自定义事件源 功能介绍 更新自定义事件源定义。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI PUT /v1/{project_id}/sources/{source_id}
能否将自定义事件推送到EventGrid? 可以。 您可以将自定义事件以CloudEvents V1.0的格式要求进行封装,并通过API将其发送到EventGrid。 请参考自定义事件发送流程,将自定义事件推送到EventGrid。
mqCall" } 查看目标函数日志。 进入函数工作流控制台,左侧导航栏选择“函数 > 函数列表”,单击目标函数名称进入详情页面。 在详情页面内,选择“监控 > 日志 > 请求列表”,单击列表中的请求ID名称,即可查看日志详情。 父主题: 创建自定义事件源
创建自定义事件源失败的原因? 创建分布式消息服务RabbitMQ版或分布式消息服务RocketMQ版事件源其状态为“创建失败”或“异常”,可能是以下原因导致: 未创建私网访问端点。 检查是否创建所需私网访问端点,其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同,具体步骤,请参考创建私网访问端点。
目标服务选择“FunctionGraph(函数计算)”。 设置事件目标参数。 图1 事件目标-FunctionGraph 表1 FunctionGraph(函数计算)参数说明 参数名称 说明 函数 选择需要触发的函数。如果还未创建函数,请先创建函数。 版本/别名 配置版本/别名,当选择其一时,则另外一个参数无需配置。
在左侧导航栏选择“事件源”,进入“事件源”页面。 单击“自定义事件源”,弹出“创建自定义事件源”对话框。 参考表1,填写自定义事件源的配置信息。 表1 RocketMQ事件源参数说明 参数名称 说明 配置类型 支持以下两种类型: 选择:选择一个已创建的自定义事件通道。 新建:创建一个新的自定义事件通道。 通道 “配
查询单个函数的EG触发器 功能介绍 查询触发器,支持指定函数urn,一个以函数urn为目标的订阅为一个触发器。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET
创建自定义事件模型版本 功能介绍 创建自定义事件模型版本,版本号后台自动生成 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id
查询单个函数流的EG触发器 功能介绍 查询触发器,支持指定函数流id,一个以函数流id为目标的订阅为一个触发器。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET
自定义事件是否支持批量发送?该如何封装? 支持。 事件网格支持以对象数组封装的方式进行批量事件发送,其中数组中每个元素都需要遵循CloudEvents V1.0标准格式要求。 更多详情请参见CloudEvents SDK。
如何将自定义的事件内容传输到事件目标? 您可以在事件订阅中通过配置事件目标的转换规则来实现将自定义的事件内容传输到事件目标。 EventGrid事件转换目前支持透传、变量、常量三种转换类型。 透传:事件网格不对事件进行转换,将CloudEvents标准事件直接路由到事件目标。 变
主动刷新token,设置事件流状态为ERROR,自动重启事件流。 等待自动恢复。 600 升级中 无动作。 采集函数正在升级,等待升级即可。 403 目标函数被禁用 设置事件流状态为ERROR,上报告警。 检查函数是否正常。 516 topic不存在 检查topic。 510 开启ACL的rocketMq认证失败
事件目标未被触发,可能是以下原因导致: 目标函数参数填写错误。 在事件订阅中使用函数工作流中的函数作为事件目标时,检查选择的源、package、函数名是否与预期相符。 事件目标的规则配置错误。 在事件订阅中配置事件目标时,检查选择的转换类型是否与预期相符。 自定义事件目标中,地址存在拼写错误、非法域名、无效IP等情况。
事件流配置完成后,单击右上角“保存”,并在事件流列表中的右侧“操作”列单击“启用”。 左上角单击,搜索“函数工作流”单击进入函数工作流控制台,左侧导航栏选择“函数 > 函数列表”,单击创建好的函数名称进入详情页。 选择“代码”页签,在编辑区增加如下代码,然后单击“部署”刷新代码。 print("body
在函数服务的监控中查看代码执行详情 在“函数列表”中找到进行数据同步的函数: 图1 函数列表 单击监控中对应的请求查看代码日志: 图2 代码日志 父主题: 实施步骤
单击“下一步”完成规则配置,您可以参考路由到函数工作流,继续配置事件流的事件目标。 事件源配置为社区版RocketMQ时,配置事件目标为FunctionGraph(函数计算)时,执行方式可选择为“同步”或“异步”。 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。 MQ采集函数首次启动分钟级后生效。
创建事件源如何配置安全组? 创建分布式消息服务RabbitMQ版或分布式消息服务RocketMQ版自定义事件源之前,需要正确配置安全组规则。 分布式消息服务所属的安全组“入方向规则”配置错误,会导致事件目标函数工作流无法消费事件; 用户default安全组“出方向规则”配置错误,事件源会创建失败。
"description" : "first channel" } name:自定义通道名称,由您自定义。 description:自定义通道的描述信息。 调用创建自定义事件源接口,创建一个自定义事件源。 POST https://{endpoint}/v1/{project_id}/sources
事件目标(即函数工作流服务中的函数)。 前提条件 已开通事件网格服务并授权。 已获取OBS和函数工作流的权限。 步骤一:创建事件目标(创建函数) 登录函数工作流控制台。 在左侧导航栏选择“函数 > 函数列表”,进入函数列表页面。 单击“创建函数”,进入“创建空白函数”页面。 参考
专享版事件流集群”,进入“专享版事件流集群”页面。 右上角单击“购买集群”,进入配置页面,配置信息介绍如下: 基本配置。 计费模式:默认按需计费。 集群名称:用户自定义。 描述:用户自定义。 源库和目标库配置。 源库类型:“Kafka”和“RocketMQ”。 目标库类型:“Kafka”和“RocketMQ”。 集群节点规格:默认“10