-
发送OBS事件 - 事件网格 EG
事件类型中描述的事件(如上传、覆盖),在OBS中触发后,根据事件订阅中事件类型的选择,可对该事件进行路由传递。例如在桶名为test_zzy的OBS源桶中上传“test.txt”文件,目录为“success”。 图2 OBS桶列表 父主题: 实施步骤
-
事件内容转换 - 事件网格 EG
"datacontenttype": "application/json", "dataschema": "", "subject": "test.txt", "time": "2023-08-01T11:41:51.712759419Z", "ttl": "4000",
-
发送OBS事件 - 事件网格 EG
在OBS管理控制台左侧导航栏选择“桶列表”。 在桶列表单击已创建的桶“eg-obs”,进入“对象”页面。 进入待上传的文件夹,单击“上传对象”,系统弹出“上传对象”对话框。 上传一个本地已准备好的文件,单击“上传”。 更多上传对象文件的方法请参考上传对象。 图1 上传对象 父主题: 实施步骤
-
分布式消息服务Kafka版 - 事件网格 EG
SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M; 压缩包里证书的名称必须是固定的:client.jks。 SASL证书密钥 当Kafka实例开启SASL
-
在OBS目标桶查看对象是否已完成同步 - 事件网格 EG
在OBS目标桶查看对象是否已完成同步 该数据同步功能默认同步后路径一致,在目标桶桶目录下查看文件是否同步成功: 图1 目标桶目录 父主题: 实施步骤
-
过滤规则示例 - 事件网格 EG
"enable" } }] } 后缀不匹配 指定某个字段的值进行后缀不匹配。如下表所示,过滤规则只匹配“subject”字段不以“txt”结尾的事件。 从事件源接收的事件 过滤规则 过滤后的事件 { "events":[{ "id": "4b26115b-778e-11ec-******"
-
云服务事件源 - 事件网格 EG
API网关 APIG 数据仓库服务 DWS 部署 CloudDeploy 统一身份认证 IAM 事件网格 EG 华为云UCS UCS 弹性文件服务 SFS CloudIDE 人脸识别 FRS 微服务引擎 CSE 云专线 DC 数据可视化 DLV NAT网关 NAT 云桌面 Workspace
-
实施及验证 - 事件网格 EG
SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M; 压缩包里证书的名称必须是固定的:client.jks。 SASL证书密钥 当Kafka实例开启SASL
-
授权委托 - 事件网格 EG
的委托。 DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络,需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。 首次创建自定义事件源“事件源类型”选择“分布式消息服务RabbitMQ版”或“分布式消息服务RocketMQ版
-
如何在创建事件源为移动云 RocketMQ版的事件流时,获取客户端SDK地址? - 事件网格 EG
请下载1.4.0版本的 Java SDK 将jar包打包成zip文件 参考创建桶,创建一个OBS桶,桶的区域与EG服务的区域保持一致,其“桶策略”需为“公共读”或“公共读写”。 参考上传文件,在桶的根目录下上传打包的ZIP文件。 在OBS中单击上传的对象,可以复制链接地址,此地址即为客户端SDK地址。
-
创建FG函数 - 事件网格 EG
进入新建的函数详情页。 在“代码”页签,代码选择“上传自ZIP文件”,上传样例代码中的程序包。 在“设置 > 环境变量”页签,输入环境信息,完成后单击“保存” 表1 参数说明 参数 说明 obs_endpoint index.py文件中定义的存放输出图片的OBS桶的地址参数,值obs.region
-
创建事件订阅 - 事件网格 EG
对象名编码:开启 过滤规则:根据默认值配置,无需修改。配置过滤规则请参考过滤规则参数说明。 对象名前缀、对象名后缀填写时,对象文件格式必须都符合才能触发事件,当前后缀为空时,任意对象文件都符合。 因目前OBS只对白名单用户开放,请在创建事件订阅前添加OBS白名单。 配置事件目标。 配置如下事件目标参数:
-
错误码 - 事件网格 EG
00516016 压缩包中找不到证书文件。 压缩包中找不到证书文件。 请检查压缩包内容,确保证书文件存在 400 EGS.00516017 文件个数超过最大限制。 文件个数超过最大限制。 请检查压缩包内文件个数 400 EGS.00516018 文件大小超过最大限制。 文件大小超过最大限制。 请检查压缩包内文件大小
-
如何获取分布式消息服务Kafka实例的SASL证书地址? - 事件网格 EG
a-certs.zip”的文件。 参考创建桶,创建一个OBS桶,桶的区域与Kafka实例区域保持一致,其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文件,在桶的根目录下上传“kafka-certs.zip”文件。 参考如下格式获取SASL证书地址:
-
查询审计事件 - 事件网格 EG
CSV格式的表格文件导出,该CSV文件包含了本次查询结果的所有事件,且最多导出5000条信息。 选择完查询条件后,单击“查询”。 在事件列表页面,您还可以导出操作记录文件和刷新列表。 单击“导出”按钮,云审计服务会将查询结果以CSV格式的表格文件导出,该CSV文件包含了本次查询结
-
状态码 - 事件网格 EG
请求格式正确,但是由于含有语义错误,无法响应。 429 TooManyRequests 表明请求超出了客户端访问频率的限制或者服务端接收到多于它能处理的请求。建议客户端读取相应的Retry-After首部,然后等待该首部指出的时间后再重试。 500 InternalServerError 表明服务端能被请求访问到,但是不能理解用户的请求。
-
创建EG事件订阅 - 事件网格 EG
过滤规则 根据默认值配置,无需修改。配置过滤规则请参考过滤规则参数说明。 说明: 对象名前缀、对象名后缀填写时,对象文件格式必须都符合才能触发事件,当前后缀为空时,任意对象文件都符合。 配置事件目标。 表2 参数配置说明 参数 说明 选择提供方 请选择“华为云”。 事件目标 请选择“F