检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
SASL_SSL 认证机制:SCRAM-SHA-512 用户名:kafka实例的用户名“kafka-name”, 密码:输入kafka实例密码 确认模式:Leader Only 单击“确定”,当目标连接状态变为正常时,完成目标连接的创建。 父主题: 实施步骤
提供方选择“云服务”。 事件目标:选择FunctionGraph(函数计算)。 函数:选择函数。 版本:选择版本。 委托:选择委托。 类型:选择透传、变量或常量。 图6 事件目标配置 图7 生成的订阅 全量配置方式可参考《创建事件订阅》。 进入目标通道的事件轨迹页面,查看投递状态。 图8
n:invoke*”。 配置规则 类型 事件网格将CloudEvents标准事件转换成事件目标可以接受的事件类型。支持以下三种转换类型: 透传:事件网格不对事件进行转换,将原生事件的完整结构直接路由到事件目标。 变量:事件网格EventGrid通过JSONPath从事件中提取参数,然后把这些参数路由到事件目标。
事件目标:选择“FunctionGraph(函数计算)” 函数:选择步骤一中创建的“test”函数 版本:选择“latest” 类型:选择“透传” 图3 设置事件目标参数 单击“确定”,完成事件目标的配置。 单击“保存”,完成事件订阅的配置。 步骤三:产生OBS事件(创建OBS桶)
消息将发送至同一分区。 规则配置 类型 事件网格将CloudEvents标准事件转换成事件目标可以接受的事件类型。支持以下三种转换类型: 透传:事件网格不对事件进行转换,将原生事件的完整结构直接路由到事件目标。 变量:事件网格EventGrid通过JSONPath从事件中提取参数,然后把这些参数路由到事件目标。
储目录/年/月/日”。 规则配置 类型 事件网格将CloudEvents标准事件转换成事件目标可以接受的事件类型。支持以下三种转换类型: 透传:事件网格不对事件进行转换,将原生事件的完整结构直接路由到事件目标。 变量:事件网格EventGrid通过JSONPath从事件中提取参数,然后把这些参数路由到事件目标。
式可选择为“同步”或“异步”。 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。 MQ采集函数首次启动分钟级后生效。 广播模式下不支持失败重试,即消费失败后,失败消息不再重试,消费者继续消费新的消息。 发送到目标端失败时,将利用RocketMQ本身的重试能力进行重
考为什么买了资源包,按需产品还会产生扣费?识别产生按需计费的原因,并重新选择正确的资源包或保证账户中的余额充足。 未购买资源包,在按需计费模式下账户的余额不足。 欠费影响 当您的账号因自动扣费导致欠费后,账号将变成欠费状态。欠费后,事件网格不会立即停止服务,会进入宽限期。您需支付
事件目标:选择“FunctionGraph(函数计算)” 函数:选择步骤三中创建的“test”函数 版本:选择“latest” 委托:选择已创建的委托。 类型:选择“透传” 图5 配置事件目标参数 单击“确定”,完成事件目标的配置。 单击“保存”,完成事件订阅的配置。 步骤五:发送自定义事件 配置自定义事件,具体请参考CloudEvents
式可选择为“同步”或“异步”。 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。 MQ采集函数首次启动分钟级后生效。 广播模式下不支持失败重试,即消费失败后,失败消息不再重试,消费者继续消费新的消息。 发送到目标端失败时,将利用RocketMQ本身的重试能力进行重
式可选择为“同步”或“异步”。 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。 MQ采集函数首次启动分钟级后生效。 广播模式下不支持失败重试,即消费失败后,失败消息不再重试,消费者继续消费新的消息。 发送到目标端失败时,将利用RocketMQ本身的重试能力进行重
用户名 Kafka实例开启SASL_SSL认证时可见,输入实例用户名。 密码 Kafka实例开启SASL_SSL认证时可见,输入实例密码。 确认模式 Kafka客户端收到Server端确认信号个数,表示producer需要收到多少个这样的确认信号,算消息发送成功。 None:表示pro
获取项目ID 操作场景 在调用接口的时候,部分URL中需要填入项目ID,所以需要获取到项目ID。有如下两种获取方式: 调用API获取项目ID 从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET ht
事件轨迹详情 功能介绍 事件轨迹详情,展示事件源到投递目标的投递情况。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/ev
分布式消息服务RocketMQ版 本章节介绍在控制台添加分布式消息服务RocketMQ版自定义事件源的方法。 前提条件 (可选)创建自定义事件源前,需要先创建自定义事件通道。 已购买分布式消息服务RocketMQ版实例,实例中已创建Topic,且实例状态处于“运行中”。具体步骤,请参考购买实例。
分布式消息服务RabbitMQ版 本章节介绍在控制台添加分布式消息服务RabbitMQ版自定义事件源的方法。 分布式消息服务RabbitMQ版当前支持局点:上海一、上海二、北京四、华北-乌兰察布一、华南-广州。 前提条件 (可选)创建自定义事件源前,需要先创建自定义事件通道。 已
创建自定义事件源 功能介绍 创建用户自定义类型的事件源,只能指定自定义通道,不能指定系统通道。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/sources
发布官方事件到事件通道 功能介绍 发布官方事件到事件通道。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/officia
发布事件到事件通道 功能介绍 发布事件到事件通道,仅供调试使用。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/chan
CloudEvents SDK 本章节介绍使用开源的CloudEvents Java SDK发布事件。 前提条件 获取并安装IntelliJ IDEA,如果未安装,请至IntelliJ IDEA官方网站下载。 在pom.xml中加入依赖。如何在Java环境中集成API请求签名的SDK请参考AK/SK签名认证操作指导。