检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
开通事件网格服务并授权 使用事件网格服务前,您需要: 已注册华为账号并开通华为云。 当前登录账号拥有使用事件网格的权限。账号权限授权与绑定,请参考创建用户并授权使用EG。 如果您的账号为IAM用户,请先联系华为云账号拥有者为IAM用户授权,然后才能使用事件网格服务。 登录事件网格控制台
云审计服务支持的关键操作 云审计服务支持的EG操作列表 在CTS事件列表查看云审计事件
华为云服务事件发送流程 本章节介绍华为云服务事件发送的整个流程。 华为云对象存储服务(Object Storage Service,简称OBS)作为云服务事件源将产生的云服务事件发送到事件网格,事件规则对云服务事件进行过滤和转换,通过转换后的事件触发事件目标(即函数工作流服务中的函数)。
采集函数正在升级,等待升级即可。 403 目标函数被禁用 设置事件流状态为ERROR,上报告警。 检查函数是否正常。 516 topic不存在 检查topic。 510 开启ACL的rocketMq认证失败 其他未识别错误码 检查用户密码是否发生变化,确认无误请联系华为工程师处理。 父主题: 管理Serverless版事件流
enable_sasl_ssl Boolean kafka实例是否开启了SASL_SSL。 缺省值:false user_name String kafka实例用户名。实例开启了SASL_SSL时必填 password String kafka实例密码。实例开启了SASL_SSL时必填 acks String
专业版事件流作业 创建专业版事件流作业 删除专业版事件流作业 启用专业版事件流作业 停用专业版事件流作业 配置专业版事件流作业 父主题: 专业版事件流
事件网格将您设置的常量路由到事件目标。 如果需要了解更多转换类型的信息,请参考事件内容转换。 启用死信队列:默认不启用。启用死信队列后EG会把处理失败的事件发送到配置的队列中,若不启用则处理失败的事件将被丢弃。了解更多详情请参考死信队列。 图5 自定义事件目标配置参数 单击“确定”。
事件网格将您设置的常量路由到事件目标。 如果需要了解更多转换类型的信息,请参考事件内容转换。 启用死信队列:默认不启用。启用死信队列后EG会把处理失败的事件发送到配置的队列中,若不启用则处理失败的事件将被丢弃。了解更多详情请参考死信队列。 图8 自定义事件目标配置参数 单击“确定”,完成事件目标的配置。
事件订阅监控支持自定义时间跨度,可自定义选择查询的时间区间。 事件订阅支持多目标时,下拉选择目标后可查看指定监控,如不选择,则查看全部监控指标。 开启“自动刷新”后,指标数据会每5s刷新一次。 点击“查看更多指标详情”,可跳转至云监控CES界面。 当“周期”选择为原始值时,监控数据为原始
下拉框中事件类型根据用户需求勾选。 对象名前缀 若填写,符合规范才能触发事件。 对象名后缀 若填写,符合规范才能触发事件。 对象名编码 选择“开启”。 过滤规则 根据默认值配置,无需修改。配置过滤规则请参考过滤规则参数说明。 对象名前缀、对象名后缀填写时,对象文件格式必须都符合才能触
云审计服务支持的EG操作列表 通过云审计服务,您可以记录与事件网格相关的操作事件,便于日后的查询、审计和回溯。 表1 云审计服务支持的事件网格操作列表 操作名称 资源类型 事件名称 创建自定义事件通道 channel CreateChannel 更新自定义事件通道 channel
当选择“精确匹配”时需选择“Topics”。 副本数 是。 说明: 自动创建的Topic副本数,不能超过目标端Kafka的Broker数量。 同步消费进度 是。 说明: 开启时表示将消息消费进度同步到目标Kafka。 启动偏移量 否。 压缩算法 是,可选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。
在函数服务的监控中查看代码执行详情 在“函数列表”中找到进行数据同步的函数: 图1 函数列表 单击监控中对应的请求查看代码日志: 图2 代码日志 父主题: 实施步骤
完成参数配置后单击“立即购买”,完成事件路由创建,创建成功后可在事件路由页面查看任务状态。 事件路由任务创建完成后默认为“未启用”状态,需要单击“启用”按钮,待状态显示为“运行中”时,任务正式启用。 图5 启用事件路由 事件路由公测期间免费。 如果源端kafka和目标端kafka在不同vpc里,但是他们的b
String 消费点位 枚举值: latest earliest enable_sasl_ssl 否 Boolean SASL_SSL是否开启 sasl_mechanism 否 String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url
seek_to String 消费点位 枚举值: latest earliest enable_sasl_ssl Boolean SASL_SSL是否开启 sasl_mechanism String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url
seek_to String 消费点位 枚举值: latest earliest enable_sasl_ssl Boolean SASL_SSL是否开启 sasl_mechanism String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url
String 消费点位 枚举值: latest earliest enable_sasl_ssl 否 Boolean SASL_SSL是否开启 sasl_mechanism 否 String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url
表示匹配所有Topic,topic.* 表示匹配所有以topic为前缀的Topic。 当选择“精确匹配”时需选择“Topics”。 同步消费进度 请选择是否打开。 说明: 开启时表示将消息消费进度同步到目标Rocketmq。 启动偏移量 请选择为“最早”、“最新”或“自定义”。 压缩算法 请选择压缩算法为“non
事件网格如何收费? 事件网格根据自定义(包含云服务租户侧事件产生 )或第三方事件流入的事件数量进行计费,具体详情请参见价格计算器。 事件网格当前提供按需计费模式,这种购买方式比较灵活,按照实际使用量付费,没有最低消费。 华为云服务事件源自身产生发布的事件(任意事件状态变化 )免费,事件消费免费。