检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
根据企业的业务组织,在您的华为云账号中,给企业中不同职能部门的员工创建IAM用户,让员工拥有唯一安全凭证,并使用EG资源。 根据企业用户的职能,设置不同的访问权限,以达到用户之间的权限隔离。 将EG资源委托给更专业、高效的其他华为云账号或者云服务,这些账号或者云服务可以根据权限进行代运维。
时,“作用范围”需要选择“区域级项目”,然后在指定区域(如华北-北京1)对应的项目(cn-north-1)中设置相关权限,并且该权限仅对此项目生效;如果在“所有项目”中设置权限,则该权限在所有区域项目中都生效。访问事件网格时,需要先切换至授权区域。 权限根据授权精细程度分为角色和策略。
创建函数”,具体详情请参见创建函数。 进入新建的函数详情页。 在“代码”页签,代码选择“上传自ZIP文件”,上传样例代码中的程序包。 在“设置 > 环境变量”页签,输入环境信息,完成后单击“保存” 表1 参数说明 参数 说明 obs_endpoint index.py文件中定义的
修改已有事件目标,或者新增事件目标。 单击已有事件目标模块,修改事件目标。 单击,新增事件目标。 单击,删除已有事件目标。 设置事件目标提供方及其参数。 当提供方为“云服务”时,设置如下参数。 事件目标:选择事件目标。 当事件目标配置为“FunctionGraph(函数计算)”时: 函数:选择
Kafka最多支持40万QPS,RocketMQ支持3万QPS,DCS支持10万QPS。 网络配置。 虚拟私有云:选择已创建的虚拟私有云,如何创建请参见创建虚拟私有云和子网。 子网:选择已创建的子网,如何创建请参见为虚拟私有云创建新的子网。 请确保事件流集群配置的虚拟私有云、子网与Kafka或RocketMQ的
200 心跳成功 设置事件流状态为RUNNING,清除告警。 正常提示。 601 未知致命异常 设置事件流状态为ERROR,上报告警,自动重启事件流。 建议联系华为工程师处理。 602 网络异常 502 消费者不存在 401 目标端投递认证失败 主动刷新token,设置事件流状态为ERROR,自动重启事件流。
基于Serverless版事件流实现Kafka实例之间的数据同步 本文介绍如何应用事件网格EventGrid的Serverless版事件流功能实现分布式消息服务Kafka版实例间的数据同步。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
SDK 常见问题 了解更多常见问题、案例和解决方案 热门案例 事件网格如何收费? 事件发布失败的原因? 事件目标未被触发的原因? 能否将自定义事件推送到EventGrid? 如何过滤最终传输到事件目标的事件? 如何将自定义的事件内容传输到事件目标? 更多 远程登录 应用容器化改造介绍
配置事件源。 单击“事件源”,参考图2,设置事件源参数。 选择提供方:选择“云服务” 事件源:选择“对象存储服务” 过滤规则:保存默认 图2 设置事件源参数 单击“确定”,完成事件源的配置。 配置事件目标。 单击“事件目标”,参考图3,设置事件目标参数。 选择提供方:选择“云服务”
生产顺序性和消费顺序性组合 生产顺序 消费顺序 顺序性效果 设置消息组,保证消息顺序发送。 顺序消费 按照消息组粒度,严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。 设置消息组,保证消息顺序发送。 并发消费 并发消费,尽可能按时间顺序处理。 未设置消息组,消息乱序发送。 顺序消费 按队列存储粒度,严格顺序。
域。 在“Kafka专享版”页面,单击Kafka实例的名称“eg-kafka”,进入实例详情页面。 选择“消息查询”页签,在消息页签页面,设置查询的Topic名称“topic-eg”、分区以及查询方式。 单击“搜索”,查询消息。 单击“查看消息正文”,弹出“查看消息正文”对话框,查看消息的具体内容。
创建OBS桶 登录OBS控制台。 单击“创建桶”,进入“创建桶”页面。 参考图1,设置桶参数。关于桶参数的详细介绍,请参考创建桶。 区域:与事件网格所在区域保持一致 桶名称:输入示例如“eg-obs” 默认存储类别:选择“标准存储” 桶策略:选择“私有” 默认加密:不勾选 归档数据直读:选择“关闭”
创建OBS源桶和目标桶 登录OBS控制台。 单击“创建桶”,进入“创建桶”页面。 设置桶参数。关于桶参数的详细介绍,请参考创建桶。 表1 桶参数配置 参数 说明 区域 事件网格与所在区域保持一致。 桶名称 输入示例如“eg-test”。 默认存储类别 按需选择。 桶策略 按需选择。
默认为“Rocketmq实例”。 说明: 配置类型根据实例类型变更。 实例别名 请输入实例别名。 用于标识源端和目标端实例,建议同一个源端或目标端实例只设置一个别名。 区域 请选择资源所在区域。 项目 请选择项目。 Rocketmq实例 请选择Rocketmq实例。 用户名 请输入用户名。 密钥
登录函数工作流控制台。 在左侧导航栏选择“函数 > 函数列表”,进入函数列表页面。 单击“创建函数”,进入“创建空白函数”页面。 参考图3,设置函数参数。关于函数参数的详细介绍,请参考创建函数。 函数类型:选择“事件函数” 区域:选择业务区域 函数名称:输入“test” 委托名称:选择“未使用任何委托”
默认为“Kafka实例”。 说明: 配置类型根据实例类型变更。 实例别名 请输入实例别名。 用于标识源端和目标端实例,建议同一个源端或目标端实例只设置一个别名。 区域 请选择资源所在区域。 项目 请选择项目。 Kafka实例 请选择Kafka实例。 接入方式 支持“明文接入”或“密文接入”。
您在欠费后需要及时充值,详细操作请参见账户充值。 相关事件不再使用,您可以将它们删除,避免不必要的扣费。 您可以在“费用中心 > 总览”页面设置“可用额度预警”功能。当可用额度、通用代金券和现金券的总额度低于预警阈值时,系统自动发送短信和邮件提醒。当产生欠费后,请您及时充值使可用额度大于0。
403 Forbidden 请求被拒绝访问。 返回该状态码,表明请求能够到达服务端,且服务端能够理解用户请求,但是拒绝做更多的事情,因为该请求被设置为拒绝访问,建议直接修改该请求,不要重试该请求。 404 NotFound 所请求的资源不存在。 建议直接修改该请求,不要重试该请求。 405
事件网格提供了REST(Representational State Transfer)风格API,支持您通过HTTPS请求调用,调用方法请参见如何调用API。 约束与限制 事件网格持续增加新的功能,将不可避免对现有接口有所调整,比如增加响应参数。为了减少接口变更带来的影响,除了事件网
同结果,请严格按照需求选择消费方式。1、生产顺序为:设置消息组,保证消息顺序发送。消费方式为:顺序消费,实际消息处理结果:按照消息组粒度,严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为:设置消息组,保证消息顺序发送。消费方式为:并发消费,实际消