检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
单击“事件源”,右侧弹出“事件源”弹窗。 选择事件源提供方。 设置事件源参数。 完成后单击“下一步”。 配置规则。 单击“规则”,右侧弹出“规则”弹窗。 配置规则模式内容。 完成后单击“下一步”。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。 选择目标服务。 设置事件目标参数。 完成后单击“确定”。
Kafka版,配置事件源。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。 目标服务选择“FunctionGraph(函数计算)”。 设置事件目标参数。 图1 事件目标-FunctionGraph 表1 FunctionGraph(函数计算)参数说明 参数名称 说明 函数 选
具体创建步骤请参考创建事件函数。 图2 函数列表 选择创建的函数,单击进入函数详情页。 选择“设置 > 触发器”,单击“创建触发器”,弹出“创建触发器”对话框。 图3 创建触发器 设置以下信息。 触发器类型:选择“分布式消息服务(Kafka)”。 实例:选择与死信队列相同的Kafka实例。
请参考配置分布式消息服务 Kafka版,配置事件源。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。 目标服务选择“对象存储服务OBS”。 设置事件目标参数。 图1 对象存储服务OBS 表1 对象存储服务OBS参数说明 参数名称 说明 AK 请输入AK。 说明: 如何获取AK/SK,请参考如何获取访问密钥AK/SK。
Kafka版,配置事件源。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。 目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。 图1 分布式消息服务 Kafka版 表1 分布式消息服务 Kafka版参数说明 参数名称 说明 目标连接 选择目标连接。如
403 Forbidden 请求被拒绝访问。 返回该状态码,表明请求能够到达服务端,且服务端能够理解用户请求,但是拒绝做更多的事情,因为该请求被设置为拒绝访问,建议直接修改该请求,不要重试该请求。 404 NotFound 所请求的资源不存在。 建议直接修改该请求,不要重试该请求。 405
时,“作用范围”需要选择“区域级项目”,然后在指定区域(如华北-北京1)对应的项目(cn-north-1)中设置相关权限,并且该权限仅对此项目生效;如果在“所有项目”中设置权限,则该权限在所有区域项目中都生效。访问事件网格时,需要先切换至授权区域。 权限根据授权精细程度分为角色和策略。
根据企业的业务组织,在您的华为云账号中,给企业中不同职能部门的员工创建IAM用户,让员工拥有唯一安全凭证,并使用EG资源。 根据企业用户的职能,设置不同的访问权限,以达到用户之间的权限隔离。 将EG资源委托给更专业、高效的其他华为云账号或者云服务,这些账号或者云服务可以根据权限进行代运维。
左上角单击,配置事件流名称和描述,完成后单击“确定”。 配置Kafka事件源。 单击“事件源”,右侧弹出“事件源”弹窗。 事件提供方选择“分布式消息服务 Kafka版”。 设置事件源参数。 图1 事件源-Kafka 表1 配置参数说明 参数名称 说明 实例 选择Kafka实例。 Topic 选择Topic。 消费组
修改已有事件目标,或者新增事件目标。 单击已有事件目标模块,修改事件目标。 单击,新增事件目标。 单击,删除已有事件目标。 设置事件目标提供方及其参数。 当提供方为“华为云”时,设置如下参数。 事件目标:选择事件目标。 当事件目标配置为“FunctionGraph(函数计算)”时: 函数:选择
目标连接 用户既可以通过default目标连接来连接公网webhook,也可以通过对应虚拟私有云和子网的目标连接来连接私网webhook。 支持添加分布式消息服务Kafka版作为目标连接。 Webhook就是客户端或者代理客户端提供一个webhook的url,服务器有新数据时就往
配置事件源 选择事件源提供方。 华为云:华为云服务事件源作为事件源提供方。 自定义:您自定义的事件源作为事件源提供方。 设置事件源参数。 当提供方为“华为云”时,设置如表1所示参数。 表1 云服务事件源参数说明 参数名称 说明 事件源 选择云服务事件源。 事件类型(可选) 选择事件网格预定义的事件类型。
创建函数”,具体详情请参见创建函数。 进入新建的函数详情页。 在“代码”页签,代码选择“上传自ZIP文件”,上传样例代码中的程序包。 在“设置 > 环境变量”页签,输入环境信息,完成后单击“保存” 表1 参数说明 参数 说明 obs_endpoint index.py文件中定义的
件目标是否已是连通状态,已配置的事件规则是否生效,事件是否成功发送到事件目标。 前提条件 已创建自定义事件通道 已创建自定义应用事件源 已设置事件目标,并基于上述内容创建事件订阅 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件通道”,进入“事件通道”页面。 单击“发布事件”,进入“发布事件”页面。
配置事件源。 单击“事件源”,参考图2,设置事件源参数。 选择提供方:选择“华为云” 事件源:选择“对象存储服务” 过滤规则:保存默认 图2 设置事件源参数 单击“确定”,完成事件源的配置。 配置事件目标。 单击“事件目标”,参考图3,设置事件目标参数。 选择提供方:选择“华为云”
生产顺序性和消费顺序性组合 生产顺序 消费顺序 顺序性效果 设置消息组,保证消息顺序发送。 顺序消费 按照消息组粒度,严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。 设置消息组,保证消息顺序发送。 并发消费 并发消费,尽可能按时间顺序处理。 未设置消息组,消息乱序发送。 顺序消费 按队列存储粒度,严格顺序。
您可以从地区和终端节点获取。 scope参数定义了Token的作用域,上面示例中获取的Token仅能访问project下的资源。您还可以设置Token作用域为某个账号下所有资源或账号的某个project下的资源,详细定义请参见获取用户Token。 POST https://iam
时间范围:可选择查询最近1小时、最近1天、最近1周的操作事件,也可以自定义最近7天内任意时间段的操作事件。 在事件列表页面,您还可以导出操作记录文件、刷新列表、设置列表展示信息等。 在搜索框中输入任意关键字,按下Enter键,可以在事件列表搜索符合条件的数据。 单击“导出”按钮,云审计服务会将查询结果以
域。 在“Kafka专享版”页面,单击Kafka实例的名称“eg-kafka”,进入实例详情页面。 选择“消息查询”页签,在消息页签页面,设置查询的Topic名称“topic-eg”、分区以及查询方式。 单击“搜索”,查询消息。 单击“查看消息正文”,弹出“查看消息正文”对话框,查看消息的具体内容。
产品功能 事件网格作为一种Serverless的事件总线服务,支持接入多种类型的事件源和事件目标,提供事件过滤路由的能力。 事件源 事件源是事件的来源,负责生产事件。事件网格支持以下事件源: 华为云服务事件源:华为云服务作为事件源,华为云服务包含弹性云服务器、对象存储服务和云容器引擎等等。