-
查看事件消息 - 事件网格 EG
选择“消息查询”页签,在消息页签页面,设置查询的Topic名称“topic-eg”、分区以及查询方式。 单击“搜索”,查询消息。 单击“查看消息正文”,弹出“查看消息正文”对话框,查看消息的具体内容。 图1 事件消息 父主题: 实施步骤
-
删除自定义事件模型 - 事件网格 EG
在“自定义事件模型”页签中,通过以下任意一种方式删除自定义事件模型。 单击待删除自定义事件模型后的“删除”,弹出“删除事件模型”对话框。 单击待删除自定义事件模型的标识,进入自定义事件模型详情页。单击“删除”,弹出“删除事件模型”对话框。
-
创建事件路由 - 事件网格 EG
如果源端kafka和目标端kafka在不同vpc里,但是他们的broker地址存在重叠,这种情况任务也会失败,规避方式是让用户用一个新的vpc打通其中一个kafka的网络,保障源端和目标端的地址不重叠。
-
分布式消息服务RocketMQ版 - 事件网格 EG
消费方式 请选择“并发消费”或“顺序消费”。 消费线程数 请输入20到64之间的整数。 批量消费最大消息数 请输入1到32之间的整数。 最大重试次数 请输入最大重试次数。 说明: 设置-1表示无限重试,0表示不重试。
-
创建EG事件订阅 - 事件网格 EG
执行方式 按需选择。 委托 选择委托。如无委托,可单击旁边的“创建委托”进行创建,将会创建名为“EG_TARGET_AGENCY”委托。 类型 按需选择。 父主题: 实施步骤
-
管理自定义事件模型版本 - 事件网格 EG
在“自定义事件模型”页签中,通过以下任意一种方式创建新版本。 单击待创建新版本的自定义事件模型后的“添加版本”,弹出“添加版本”对话框。 单击待创建新版本的自定义事件模型的标识,进入自定义事件模型详情页。在“版本列表”页签,单击“添加版本”,弹出“添加版本”对话框。
-
事件网格 EG - 事件网格 EG
通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件,帮助您轻松构建松耦合、分布式的事件驱动架构。
-
权限管理 - 事件网格 EG
基于策略的授权是一种更加灵活的授权方式,能够满足企业对权限最小化的安全管控要求。例如:针对事件网格服务,管理员能够控制IAM用户仅能对事件源进行指定的管理操作。多数细粒度策略以API接口为粒度进行权限拆分。 IAM用户授权时请选择“IAM项目视图”方式。
-
构造请求 - 事件网格 EG
X-Auth-Token:用户Token,可选,当使用Token方式认证时,必须填充该字段。用户Token也就是调用获取用户Token接口的响应值,该接口是唯一不需要认证的接口。
-
路由到函数工作流 - 事件网格 EG
执行方式 默认“同步”。 委托 选择委托。如无委托,可单击旁边的“快速创建委托”进行创建,将会创建名为“EG_INVOKE_FG_AGENCY”委托。 委托下拉框只会查询出被委托方是事件网格服务的委托。
-
社区版RocketMQ - 事件网格 EG
事件源配置为社区版RocketMQ时,配置事件目标为FunctionGraph(函数计算)时,执行方式可选择为“同步”或“异步”。 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。 MQ采集函数首次启动分钟级后生效。
-
跨账号事件发送流程 - 事件网格 EG
图6 事件目标配置 图7 生成的订阅 全量配置方式可参考《创建事件订阅》。 进入目标通道的事件轨迹页面,查看投递状态。 图8 投递状态 投递状态显示“投递成功”,跨账号事件发送成功。
-
查询事件订阅监控指标数据 - 事件网格 EG
URI GET /v1/{project_id}/metrics/sub 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 表2 Query参数 参数 是否必选 参数类型 描述 filter 否 String 指标数据统计方式 缺省值
-
查询事件通道监控指标数据 - 事件网格 EG
URI GET /v1/{project_id}/metrics/pub 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 表2 Query参数 参数 是否必选 参数类型 描述 filter 否 String 指标数据统计方式 缺省值
-
编辑事件订阅 - 事件网格 EG
执行方式:选择异步或同步。 请求函数调用的方式,默认采用异步执行。 异步:异步执行指的是函数调用请求发送后不等待函数调用结果。 同步:同步执行指的是函数调用请求需要明确等到响应结果,也就是说这样的请求必须得调用到用户的函数,并且等到调用完成才返回。 委托:选择委托。
-
查询事件目标分类 - 事件网格 EG
1或大于1000 最小值:1 最大值:1000 缺省值:15 sort 否 String 指定查询排序 缺省值:created_time:DESC fuzzy_label 否 String 指定查询的事件目标标签,模糊匹配 support_types 否 Array 事件目标支持方式
-
目标连接 - 事件网格 EG
接入方式 选择“密文接入”或“明文接入”。 安全协议 当选择为密文接入时会显示对应的安全协议。 SASL_SSL 认证机制 Kafka实例开启SASL_SSL认证时可见,选择SASL_SSL 认证机制。 PLAIN:一种简单的用户名密码校验机制。
-
创建事件订阅 - 事件网格 EG
执行方式:选择异步或同步。 请求函数调用的方式,默认采用异步执行。 异步:异步执行指的是函数调用请求发送后不等待函数调用结果。 同步:同步执行指的是函数调用请求需要明确等到响应结果,也就是说这样的请求必须得调用到用户的函数,并且等到调用完成才返回。 委托:选择委托。
-
创建事件订阅目标 - 事件网格 EG
参数类型 描述 url 否 String 自定义目标url agency_name 否 String 委托名称 invocation_http_parameters 否 InvocationHttpParameters object invoke_type 否 String 函数调用方式
-
更新事件订阅目标 - 事件网格 EG
参数类型 描述 url 否 String 自定义目标url agency_name 否 String 委托名称 invocation_http_parameters 否 InvocationHttpParameters object invoke_type 否 String 函数调用方式