响应消息头中X-Subject-Token的值)。 响应参数 状态码:204 删除成功 无 请求示例 删除自定义事件源 DELETE https://{endpoint}/v1/{project_id}/sources/{source_id} 响应示例 无 状态码 状态码 描述 204
CloudEvents SDK 本章节介绍使用开源的CloudEvents Java SDK发布事件。 前提条件 获取并安装IntelliJ IDEA,如果未安装,请至IntelliJ IDEA官方网站下载。 在pom.xml中加入依赖。如何在Java环境中集成API请求签名的SDK请参考AK/SK签名认证操作指导。
创建专业版事件流作业 功能介绍 创建专业版事件流作业 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/eventrouter/jobs
社区版RocketMQ 本章节介绍在事件流里添加社区版RocketMQ事件源的方法。 目前支持RocketMQ的开源版本:4.9.7/5.1.4。 前提条件 已有社区版RocketMQ集群实例。 当源端为社区版RocketMQ时,目标端只支持选择FunctionGraph(函数计算)。
取(响应消息头中X-Subject-Token的值)。 响应参数 状态码:204 详情 无 请求示例 删除事件模型版本 DELETE https://{endpoint}/v1/{project_id}/schemas/{schema_id}/versions/{version}
图1 源数据和目标数据配置 表2 源数据和目标数据配置参数说明 参数 说明 配置类型 默认为“DCS实例”。 说明: 配置类型根据实例类型变更。 区域 请选择资源所在区域。 项目 请选择项目。 DCS实例 请选择DCS实例。 单击“下一步:高级配置”,进入“高级配置”页面。 图2
您还可以查看审计日志,以便日后的审计和回溯。 日常操作 创建自定义事件源 事件通道 创建事件订阅 创建事件流 过滤规则参数说明 事件内容转换 网络管理 运维与监控 支持云审计的操作列表 查看云审计日志 事件监控 04 SDK 事件网格提供开源的CloudEvents SDK,并
更新专业版事件流作业 功能介绍 更新专业版事件流作业 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI PUT /v1/{project_id}/eventrouter/jobs/{job_id}
查询专业版事件流作业详情 功能介绍 查询专业版事件流作业详情 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/eventrouter/jobs/{job_id}
eventStreamingID String 事件流ID 请求示例 停止eventstreaming_id=123的事件流 POST https://{eg_endpoint}/v1/{project_id}/eventstreamings/operate/123 { "operation"
创建事件路由 事件路由概述 事件路由基于SmartConnect实现能力同步数据的同步。 约束与限制 事件路由公测期间免费。 如果源端kafka和目标端kafka在不同vpc里,但是他们的broker地址存在重叠,这种情况任务也会失败,规避方式是让用户用一个新的vpc打通其中一个
更新自定义事件源 功能介绍 更新自定义事件源定义。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI PUT /v1/{project_id}/sources/{source_id}
分布式消息服务RocketMQ版 本章节介绍在事件流里添加分布式消息服务RocketMQ版事件源的方法。 前提条件 已在分布式消息服务RocketMQ版中购买RocketMQ实例。 当源端为分布式消息服务RocketMQ版时,目标端只支持选择FunctionGraph(函数计算)。
专业版事件流概述 事件网格(EventGrid,简称EG)专业版事件流作为易用、稳定、高效的数据同步管道连接不同的系统与服务,支持中间件数据在线实时同步。事件流围绕云中间件,降低了中间件之间数据流通的复杂性,有效地帮助您减少数据传输的成本。适用于上云、跨云、云内跨地域中间件数据搬
String 更新UTC时间 enterprise_project_id String 企业项目id 请求示例 查询事件通道详情 GET https://{endpoint}/v1/{project_id}/channels/{channel_id} 响应示例 状态码:200 详情 {
创建自定义事件源 功能介绍 创建用户自定义类型的事件源,只能指定自定义通道,不能指定系统通道。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/sources
rth-1)中设置相关权限,并且该权限仅对此项目生效;如果在“所有项目”中设置权限,则该权限在所有区域项目中都生效。访问事件网格时,需要先切换至授权区域。 权限根据授权精细程度分为角色和策略。 角色:IAM最初提供的一种根据用户的工作职能定义权限的粗粒度授权机制。该机制以服务为粒
发送事件是否成功检查结果 check_detail String 发送事件是否成功检查明细 请求示例 预校验指定事件源发布事件成功 POST https://{endpoint}/v1/{project_id}/events/check { "sources" : [ { "channel_id"
process_time Long 处理时间 invoke_time Long 调用时间 请求示例 按平均统计方式查询事件订阅监控指标数据 GET https://{eg_endpoint}/v1/{project_id}/metrics/sub filter:AVG 响应示例 状态码:200
配置专业版事件流作业 登录事件网格控制台,本章节以配置Kafka事件流作业为例介绍。 在左侧导航栏选择“事件流>专业版事件流作业”,进入“专业版事件流作业”页面。 先停用事件流作业,再单击操作列“修改配置”按钮,进入“基础配置”页面,此处只能修改“作业名称”和“描述”。 单击“下
您即将访问非华为云网站,请注意账号财产安全