检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在实例“基本信息>连接信息”页面,单击SSL证书旁的“下载”。 SSL证书将会下载到本地电脑,名字为“kafka-certs.zip”的文件。 参考创建桶,创建一个OBS桶,桶的区域与Kafka实例区域保持一致,其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文
获取项目ID 操作场景 在调用接口的时候,部分URL中需要填入项目ID,所以需要获取到项目ID。有如下两种获取方式: 调用API获取项目ID 从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET ht
如何在创建事件源为移动云 RocketMQ版的事件流时,获取客户端SDK地址? 用户在创建事件流时,配置事件源为移动云 RocketMQ版实例时,需要配置客户端SDK地址。 本章节介绍如何获取客户端SDK地址。 操作步骤 下载移动云RocketMQ的客户端。 https://ecloud
获取obs桶列表 功能介绍 获取obs桶列表。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/subscriptions/obsbuckets
获取API版本列表 功能介绍 获取服务支持的API版本列表。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET / 请求参数 无 响应参数 状态码: 200 表1
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 最小长度:1 最大长度:16384 响应参数 状态码: 400 表3 响应Body参数
变量:从CloudEvents标准事件中获取变量值,将变量值按照模板定义的格式路由到事件目标。 常量:事件只能触发事件目标,但是不会传送事件内容到事件目标,事件网格将您设置的常量路由到事件目标。 关于转换规则的更多示例信息,请参考事件内容转换。
凭证,获取项目ID。 CHANNEL_ID:参考收集信息,获取通道ID。 ENDPOINT:事件网格访问端点,如“华北-北京四”区域,公网访问端点值为“events.cn-north-4.myhuaweicloud.com”。 SOURCE:即事件源名称,参考收集信息,获取Filter中的values值。
求消息头之外的内容。若请求消息体中参数支持中文,则中文字符必须为UTF-8编码。 每个接口的请求消息体内容不同,也并不是每个接口都需要有请求消息体(或者说消息体为空),GET、DELETE操作类型的接口就不需要消息体,消息体具体内容需要根据具体接口而定。 对于获取用户Token接
在创建事件订阅-配置事件目标,事件目标配置为“FunctionGraph(函数计算)”时,若内容转换规则配置为“透传”,无法将事件内容作为输入值传递至事件目标。如需将事件内容作为函数流输入值,可以通过“变量”或“常量”的内容转换规则,规则必须包含input字段,示例如下: 表1 变量示例 转换前的事件
事件发布失败的原因? 事件发布失败,可能是以下原因导致: 接口无访问权限。 检查AK/SK是否正确,如果需要重新获取AK/SK,请参考获取AK/SK。 请求鉴权失败。 检查发布事件的请求方法、请求地址和请求体与利用验签算法生成签名时的参数是否一致。 资源不存在。 请检查事件通道、
调用其他API。 图1 获取用户Token响应消息头 响应消息体(可选) 响应消息体通常以结构化格式返回,与响应消息头中Content-type对应,传递除响应消息头之外的内容。 对于获取用户Token接口,返回如下消息体。为篇幅起见,这里只展示部分内容。 { "token":
事件规则对自定义事件进行过滤和转换,通过转换后的事件触发事件目标(即函数工作流服务中的函数)。 前提条件 已开通事件网格服务并授权。 已获取函数工作流的权限。 步骤一:创建自定义通道 登录事件网格控制台。 在左侧导航栏选择“事件通道”,进入“事件通道”页面。 单击“创建事件通道”,弹出“创建事件通道”对话框。
获取账号名和账号ID 在调用接口的时候,部分URL中需要填入账户名和账户ID,所以需要先在管理控制台上获取到账户名和账户ID。账户名和账户ID获取步骤如下: 登录管理控制台。 鼠标悬停在右上角的用户名,选择下拉列表中的“我的凭证”。 查看账户名和账户ID。 图1 查看账户名和账户ID
设置事件目标参数。 图1 对象存储服务OBS 表1 对象存储服务OBS参数说明 参数名称 说明 AK 请输入AK。 说明: 如何获取AK/SK,请参考如何获取访问密钥AK/SK。 SK 请输入SK。 桶 请选择/输入OBS桶名称。 转储目录 请输入转储目录。 说明: OBS桶中对象的目录,多级目录用“/”分隔。
收集信息 在使用开源的CloudEvents SDK发布事件前,您需要先获取以下信息。 通道ID 在事件网格控制台的左侧导航栏中选择“事件通道”,通道名称下的一串字符即为通道ID,如下图所示。 过滤规则中的values值 在事件网格控制台的左侧导航栏中选择“事件订阅”,单击订阅名称,进入订阅详情页。
过滤规则参数说明和过滤规则示例。 转换:事件网格在事件订阅中通过配置类型对事件内容进行转换,将CloudEvents标准事件转换成事件目标可以接受的事件类型。关于事件内容转换的更多信息,请参考事件内容转换。 父主题: 事件规则
安全认证机制,比PLAIN机制安全性更高。 SASL证书地址 当Kafka实例开启SASL SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M;
安全认证机制,比PLAIN机制安全性更高。 SASL证书地址 当Kafka实例开启SASL SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M;
快速入门 场景描述 您可以根据业务需要创建一个自定义事件源。 API调用方法请参考如何调用API。 前提条件 已获取IAM的Endpoint,具体请参见地区和终端节点。 已获取事件网格的Endpoint,具体请参见地区和终端节点。 创建自定义事件源 调用创建自定义事件通道接口,创建一个自定义通道。