检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
专业版事件流集群”,进入“专业版事件流集群”页面。 右上角单击“购买集群”,进入配置页面,配置信息介绍如下: 基本配置。 计费模式:默认按需计费。 集群名称:用户自定义。 描述:用户自定义。 源库和目标库配置。 源库类型:“Kafka”和“RocketMQ”。 目标库类型:“Kafka”和“RocketMQ”。
认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败)回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待leader已经成功将数据写
认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败)回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待leader已经成功将数据写
age、函数名是否与预期相符。 事件目标的规则配置错误。 在事件订阅中配置事件目标时,检查选择的转换类型是否与预期相符。 自定义事件目标中,地址存在拼写错误、非法域名、无效IP等情况。 检查域名或IP地址是否正确配置。IP地址不能配置为保留IP地址,例如:全0地址/环回地址/ECS链路地址169
单击“创建Serverless版事件流”,然后单击左上角图标,输入事件流名称和描述,完成后单击“确定”。 请参考配置分布式消息服务 Kafka版,配置事件源。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。 目标服务选择“对象存储服务OBS”。 设置事件目标参数。
模板 My name is ${name} My name is test01 在创建事件订阅-配置事件目标,事件目标配置为“FunctionGraph(函数计算)”时,若内容转换规则配置为“透传”,无法将事件内容作为输入值传递至事件目标。如需将事件内容作为函数流输入值,可以通过“
发布事件 本章节介绍在事件网格控制台如何发布事件。 您可以通过发布事件功能,调试事件订阅中事件源、事件通道、事件目标是否已是连通状态,已配置的事件规则是否生效,事件是否成功发送到事件目标。 前提条件 已创建自定义事件通道 已创建自定义应用事件源 已设置事件目标,并基于上述内容创建事件订阅
例。 解决方式:返回配置专业版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为源端实例。 原因二:目标端RocketMQ实例版本不支持,请选择符合要求的实例。 解决方式:返回配置专业版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为目标端实例。
事件规则概述 事件规则用于过滤和转换事件。 过滤:事件网格在事件订阅中通过配置过滤规则过滤事件,并将过滤后的事件路由到事件目标。关于过滤规则的更多信息,请参考过滤规则参数说明和过滤规则示例。 转换:事件网格在事件订阅中通过配置类型对事件内容进行转换,将CloudEvents标准事件转换成事
登录函数工作流控制台,在左侧导航栏选择“函数 > 函数列表”,进入函数列表界面。 单击“创建函数”,进入创建函数流程。 填写函数配置信息。输入基础配置信息,完成后单击“创建函数”,具体详情请参见创建函数。 进入新建的函数详情页。 在“代码”页签,代码选择“上传自ZIP文件”,上传样例代码中的程序包。
请参考过滤规则参数说明和过滤规则示例。 图4 自定义事件源配置参数 单击“确定”,完成事件源的配置。 配置事件目标。 一个订阅最多关联五个事件目标。 单击“事件目标”,如图5所示,弹出“事件目标”对话框。 图5 配置事件目标 选择事件目标提供方。 云服务:云服务作为事件目标提供方。
当提供方为“云服务”时,设置如下参数。 事件目标:选择事件目标。 当事件目标配置为“FunctionGraph(函数计算)”时: 函数:选择需要触发的函数。如果还未创建函数,请先创建函数。 版本/别名:配置版本/别名,当选择其一时,则另外一个参数无需配置。 版本:选择函数的版本。当前默认选择“latest”。
的实例。 解决方式:返回配置专业版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为源端实例。 原因二:目标端Kafka实例版本不支持,请选择符合要求的实例。 解决方式:返回配置专业版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为目标端实例。
删除事件模型版本 功能介绍 删除事件模型指定版本 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI DELETE /v1/{project_id}/schemas/{s
查询事件模型版本详情 功能介绍 查询事件模型指定版本详情 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/schemas/{
用户名 请输入用户名。 说明: 当接入方式选择“密文接入”时需配置。 密码 请输入密码。 说明: 当接入方式选择“密文接入”时需配置。 单击“下一步:高级配置”,进入“高级配置”页面。 图2 高级配置 表3 作业对象配置参数说明 参数 说明 Topic匹配类型 选择“正则匹配”或“精确匹配”。
版本:选择“latest” 委托:选择已创建的委托。 类型:选择“透传” 图5 配置事件目标参数 单击“确定”,完成事件目标的配置。 单击“保存”,完成事件订阅的配置。 步骤五:发送自定义事件 配置自定义事件,具体请参考CloudEvents SDK。 修改发布事件示例代码中如下参数:
目标连接功能需要使用函数工作流服务打通用户VPC网络,需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络,需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。 首次创建自定义事件源“事件
操作事件流 功能介绍 操作事件流。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/eventstreamings/ope
查询服务委托 功能介绍 查询服务委托。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/service-agencies 表1