检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
网关登录 平台支持MQTT协议的connect消息接口，获取鉴权信息“clientId”、“Username”、“Password”。 参数说明 参数 必选/可选 类型 参数描述 clientId 必选 String(256) 一机一密的设备clientId由4个部分组成：dev
开发规范 开发工具版本要求： IntelliJ IDEA：2018.3.5或以上版本。 Eclipse：3.6.0或以上版本。 Visual Studio：2019 version 16.8.4或以上版本。 开发语言环境版本要求： Java：1.8.111或以上版本的Java Development
MQS连接开发（开源客户端） Java客户端使用说明 Python客户端使用说明 Go客户端使用说明 C#客户端使用说明 其他语言客户端使用说明 附录：如何提高消息处理效率 附录：spring-kafka对接限制 父主题： 消息集成开发指导
information: decrypt token fail", "error_code": "APIC.0301", "request_id": "******" } 可能原因 用户的API所属IAM认证，Token解析失败。 解决办法 检查获取Token的方法，Token是否正确。
使用Kafka客户端公网连接MQS：在“连接地址”下查看消息集成 MQS公网连接地址。 使用RESTful API连接MQS：在“MQS基本信息”下查看消息RESTful API。 获取Topic名称 在ROMA Connect实例控制台的“消息集成 MQS > Topic管理”页面，查看Topic名称。
开发规范 开发工具版本要求： IntelliJ IDEA：2018.3.5或以上版本。 Eclipse：3.6.0或以上版本。 开发语言环境版本要求： 1.8.111或以上版本的Java Development Kit。 设备开发要求： 通过MQTT协议接入设备时，当前仅支持MQTT协议中的QoS0和QoS1。
创建连接器 概述 ROMA Connect提供了常见的数据源连接支持，如关系型数据库、消息队列、API、NoSQL、对象存储等，这些数据源可以直接在ROMA Connect中使用，您只需要接入数据源，创建并启动数据集成任务，就可以将您的源端数据集成到目标端。 如果ROMA Con
Core的服务器，作为API的后端，并且实现一个IAuthorizationFilter，对APIC的请求做签名校验。 API绑定签名密钥后，发给后端的请求中才会添加签名信息。 编写一个Controller，提供GET、POST、PUT和DELETE四个接口，且加入ApigatewayS
等操作，打通地域限制，实现区域业务集成自治，集团信息共享，保障业务集成可靠性。 跨云集成：服务集成APIC将SaaS应用和其他第三方云应用转换成API接口，企业通过调用这些API接口，整合不同的云应用，确保云上的业务间无缝对接。 跨网集成：基于ROMA Connect实现与合作伙
Connect支持通过插件的方式，为API提供灵活的扩展能力。 前提条件 插件和API本身相互独立，只有为API绑定插件后，插件才对API生效。为API绑定插件时需指定发布环境，插件只对指定环境上的API生效。 同一个API在同一个环境中只能绑定一个相同类型的插件。 已被API绑定的插件无法删除。
连接器 创建连接器 发布连接器 父主题： 数据集成指导
本文介绍Java版本的Kafka客户端连接指导，并完成客户端连接以及消息生产与消费的相关示例。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Java开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1.1.0、2.7，您可以在ROMA Co
开发规范 开发建议 数据集成开发建议： ROMA Connect仅对连接器的RESTful接口做了规范定义，具体连接器对数据源的读写功能以及RESTful接口均需要您自行开发，您可以自行选择开发语言进行连接器开发。 连接器开发完成后，您需要自行部署连接器，并确保连接器所在网络与ROMA
rpid选择会话JSAPI获取。 图片链接 消息预览图链接。 表4 机器人发送文件消息 参数 说明 群聊ID 从钉钉的创建企业内部群或创建场景群接口获取。对于已存在的群，可以用钉钉的根据corpid选择会话JSAPI获取。 媒体文件ID 通过上传媒体文件接口，获取media_id参数值。
并授权的集成应用为“授权应用”。 对象 可查看和管理本集成应用下的资源，包括数据源、API、Topic和设备，您可对本集成应用下的资源进行创建、编辑、删除等操作，具体操作指导请参考数据源、API、Topic和设备的使用指导。 父主题： 集成应用管理
参数 说明 API名称 填写API的名称，自定义。 集成应用 选择创建用于前端认证的函数后端中创建的集成应用。 所属分组 选择前端API所属的API分组。若没有可用的API分组，可单击右侧的“创建分组”，创建一个API分组。 URL 配置API的URL。 请求方法：选择API的请求方法，此处选择“GET”。
Kafka客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Python开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1.1.0、2.7，您可以在ROMA
安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 80 0.0.0.0/0 通过公网访问APIC（无SSL加密）。 入方向 TCP 443 0.0.0.0/0 通过公网访问APIC（有SSL加密）。 入方向 TCP 1883 0.0.0.0/0 通过公网访问LINK（无SSL加密）。
导出全部资产：单击“导出全部资产”，导出资产文件到本地。 导出应用资产时，如果需要导出所有API资产信息，可勾选“是否导出应用中的所有API资产信息”按钮，所有API资产信息包括自有API和授权API。不勾选时，导出自有API和自有授权API信息。 完成后单击“关闭”，您可以在本地查看已导出的资产。 父主题：
您可以根据实际需要修改“容量阈值策略”。 连接地址 实例的相关对接地址，包括： ROMA Connect连接地址 设备集成LINK连接地址 服务集成APIC连接地址 服务集成 APIC内网连接地址（自定义后端组件和网关组件） 数据集成 FDI内网出口地址 消息集成 MQS内网连接地址 消息集成 MQS公网连接地址（仅绑定弹性IP地址时展示）
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
