-
如何获取分布式消息服务Kafka实例的SASL证书地址? - 事件网格 EG
在实例“基本信息>连接信息”页面,单击SSL证书旁的“下载”。 SSL证书将会下载到本地电脑,名字为“kafka-certs.zip”的文件。 参考创建桶,创建一个OBS桶,桶的区域与Kafka实例区域保持一致,其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文件
-
错误码 - 事件网格 EG
错误码 当您调用API时,如果遇到“APIGW”开头的错误码,请参见API网关错误码进行处理。 状态码 错误码 错误信息 描述 处理措施 400 EG.00513000 invalid parameters 参数错误 请检查参数是否正确 400 EG.00513001 name duplicated
-
分布式消息服务Kafka版 - 事件网格 EG
M; 压缩包里证书的名称必须是固定的:client.jks。 SASL证书密钥 当Kafka实例开启SASL SSL时可见,输入SASL证书密钥。 用户名 当Kafka实例开启SASL SSL时可见,输入实例用户名。 用户密码 当Kafka实例开启SASL SSL时可见,输入实例用户密码。
-
实施及验证 - 事件网格 EG
SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M; 压缩包里证书的名称必须是固定的:client.jks。 SASL证书密钥 当Kafka实例开启SASL
-
查询事件流列表 - 事件网格 EG
enable_sasl_ssl Boolean SASL_SSL是否开启 sasl_mechanism String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url String SASL证书地址,配置的obs地址 最小长度:1
-
查询事件流详情 - 事件网格 EG
enable_sasl_ssl Boolean SASL_SSL是否开启 sasl_mechanism String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url String SASL证书地址,配置的obs地址 最小长度:1
-
更新事件流 - 事件网格 EG
enable_sasl_ssl 否 Boolean SASL_SSL是否开启 sasl_mechanism 否 String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url 否 String SASL证书地址,配置的obs地址 最小长度:1
-
创建事件流 - 事件网格 EG
enable_sasl_ssl 否 Boolean SASL_SSL是否开启 sasl_mechanism 否 String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url 否 String SASL证书地址,配置的obs地址 最小长度:1
-
RocketMQ采集函数错误码 - 事件网格 EG
RocketMQ采集函数错误码 错误码 错误码说明 运维说明 操作建议 200 心跳成功 设置事件流状态为RUNNING,清除告警。 正常提示。 601 未知致命异常 设置事件流状态为ERROR,上报告警,自动重启事件流。 建议联系华为工程师处理。 602 网络异常 502 消费者不存在
-
事件目标未被触发的原因? - 事件网格 EG
事件目标未被触发的原因? 事件目标未被触发,可能是以下原因导致: 目标函数参数填写错误。 在事件订阅中使用函数工作流中的函数作为事件目标时,检查选择的源、package、函数名是否与预期相符。 事件目标的规则配置错误。 在事件订阅中配置事件目标时,检查选择的转换类型是否与预期相符。
-
创建自定义事件源 - 事件网格 EG
String 事件源归属的事件通道ID channel_name String 事件源归属的事件通道名称 type String 事件源类型 detail Object json格式封装消息实例链接信息:如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等
-
发布事件到事件通道 - 事件网格 EG
Object 事件的负载内容,采用datacontenttype字段指定的格式,内容字段遵循dataschema字段的描述 time 否 String 事件发生UTC日期时间,相同来源的事件格式相同,遵循RFC3339,格式需满足2018-04-05T17:31:00Z,参考https://tools
-
发布官方事件到事件通道 - 事件网格 EG
Object 事件的负载内容,采用datacontenttype字段指定的格式,内容字段遵循dataschema字段的描述 time 否 String 事件发生UTC日期时间,相同来源的事件格式相同,遵循RFC3339,格式需满足2018-04-05T17:31:00Z,参考https://tools
-
更新自定义事件源 - 事件网格 EG
String 事件源归属的事件通道ID channel_name String 事件源归属的事件通道名称 type String 事件源类型 detail Object json格式封装消息实例链接信息:如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等
-
创建事件源如何配置安全组? - 事件网格 EG
RocketMQ版自定义事件源之前,需要正确配置安全组规则。 分布式消息服务所属的安全组“入方向规则”配置错误,会导致事件目标函数工作流无法消费事件; 用户default安全组“出方向规则”配置错误,事件源会创建失败。 配置安全组规则如下: 配置分布式消息服务RabbitMQ版安
-
创建目标连接 - 事件网格 EG
enable_sasl_ssl 是 Boolean kafka实例是否开启了SASL_SSL。 缺省值:false user_name 否 String kafka实例用户名。实例开启了SASL_SSL时必填 password 否 String kafka实例密码。实例开启了SASL_SSL时必填
-
查询目标连接详情 - 事件网格 EG
enable_sasl_ssl Boolean kafka实例是否开启了SASL_SSL。 缺省值:false user_name String kafka实例用户名。实例开启了SASL_SSL时必填 password String kafka实例密码。实例开启了SASL_SSL时必填 acks
-
更新目标连接 - 事件网格 EG
enable_sasl_ssl Boolean kafka实例是否开启了SASL_SSL。 缺省值:false user_name String kafka实例用户名。实例开启了SASL_SSL时必填 password String kafka实例密码。实例开启了SASL_SSL时必填 acks
-
查询目标连接列表 - 事件网格 EG
enable_sasl_ssl Boolean kafka实例是否开启了SASL_SSL。 缺省值:false user_name String kafka实例用户名。实例开启了SASL_SSL时必填 password String kafka实例密码。实例开启了SASL_SSL时必填 acks
-
路由到分布式消息服务Kafka版 - 事件网格 EG
值作为Key值。 常量:将指定的常量作为key值。若选择常量,所有消息将发送至同一分区。 规则配置 类型 事件网格将CloudEvents标准事件转换成事件目标可以接受的事件类型。支持以下三种转换类型: 透传:事件网格不对事件进行转换,将原生事件的完整结构直接路由到事件目标。 变