检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
域名cname状态： 1：未解析 2：解析中 3：解析成功 4：解析失败 ssl_id String SSL证书编号 ssl_name String SSL证书名称 min_ssl_version String 最小ssl协议版本号。支持TLSv1.1或TLSv1.2 缺省值：TLSv1
域名cname状态： 1：未解析 2：解析中 3：解析成功 4：解析失败 ssl_id String SSL证书编号 ssl_name String SSL证书名称 min_ssl_version String 最小ssl协议版本号。支持TLSv1.1或TLSv1.2 缺省值：TLSv1
域名cname状态： 1：未解析 2：解析中 3：解析成功 4：解析失败 ssl_id String SSL证书编号 ssl_name String SSL证书名称 min_ssl_version String 最小ssl协议版本号。支持TLSv1.1或TLSv1.2 缺省值：TLSv1
brokers：MQS连接地址和端口。 topics：要生产消息的Topic名称。 user和password：开启SASL_SSL认证时所使用的用户名和密码。 caFile：开启SASL_SSL认证时所使用的客户端证书。 非SASL认证方式 注意，加粗内容需要替换为实例自有信息。 package main import
服务集成API 实例管理 API分组管理 API管理 环境管理 环境变量管理 域名管理 流控策略管理 API绑定流控策略 设置特殊流控 签名密钥管理 签名密钥绑定关系管理 ACL策略管理 API绑定ACL策略 OpenAPI接口 VPC通道管理 客户端配置 客户端配额 APP授权管理 自定义后端服务
BITMQ、IBMMQ时需要配置。 ssl_username 否 String SSL用户名/应用Key。 数据源为KAFKA或者MQS时，且开启SSL认证时需要配置。 最小长度：0 最大长度：256 ssl_password 否 String SSL密码/应用Secret。 数
T”或“SASL_SSL”时需配置。 SASL或SSL认证所使用的用户密码。 确认SASL用户密码 仅当“安全协议”选择“SASL_PLAINTEXT”或“SASL_SSL”时需配置。 SASL或SSL认证所使用的用户密码，与“SASL用户密码”保持一致。 证书内容 仅当“安全协议”选择“SASL_SSL”时需配置。
接地址。 是否SSL ROMA Connect与Kafka的连接是否使用SSL认证加密。 SSL用户名/应用Key 仅当“是否SSL”选择“是”时需要配置。 SSL认证所使用的用户名。 SSL密码/应用Secret 仅当“是否SSL”选择“是”时需要配置。 SSL认证所使用的用户密码。
“OPC UA”。 创建设备。 在“设备管理”页面单击“创建设备”，所属产品选择上一步创建的产品。 下载EdgeShell安装包。 单击设备名称，进入设备详情页，在基础信息页签中，单击的“EdgeShell”项的“下载安装包”，下载EdgeShell安装包。 启动EdgeShell。
Connect控制台的实例信息页面查看该地址。 是否SSL 仅当ROMA Connect实例的“MQS SASL_SSL”已开启且“VPC内网明文访问”未开启时，选择“是”，其他情况下选择“否”。 SSL用户名/应用Key 仅当“是否SSL”选择“是”时需要配置。 填写配置设备数据转发MQS中创建的Topic所属集成应用的Key。
选择当前实例下MQS的内网连接地址。 是否SSL ROMA Connect与MQS的连接是否使用SSL认证加密。 当MQS开启了SSL且VPC内网明文访问未开启时，请选择“是”，其他情况下选择“否”。 SSL用户名/应用Key 仅当“是否SSL”选择“是”时需要配置。 SSL认证所使用的用户名，如果使用ROMA
Connect提供的Java类实现具体功能。 脚本开发应基于内置推荐的加密算法，不建议用户自行实现。 公共配置引用 自定义后端支持添加变量、密码、证书等全局公共配置，并在函数脚本中引用。公共配置的添加操作请参考添加自定义后端公共配置。 假如配置名称为example，则引用格式如下： 模板变量：#{example} 密码：CipherUtils
getCaCertData() 获取Ca证书 返回信息 返回Ca证书 public String getCharset() 获取HTTP请求编码格式 返回信息 返回HTTP请求编码格式 public String getClientCertData() 获取客户端证书 返回信息 返回客户端证书 public
</dependency> 修改配置信息 为了方便，下文分生产与消费两个配置文件介绍。如果ROMA Connect实例开启了SASL认证，在Java客户端的配置文件中必须配置涉及SASL认证的相关信息，否则无法连接。如果没有使用SASL认证，请注释掉相关配置。 生产消息配置文件（对应生产消息代码中的mqs
http.conn.ssl.AllowAllHostnameVerifier; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.conn.ssl.SSLContexts;
自定义后端”，在“配置管理”页面单击“添加配置”。 在添加配置弹窗中配置相关信息，完成后单击“确定”。 表1 公共配置 参数 说明 配置名称 填写配置的名称，根据规划自定义。 所属集成应用 选择配置所归属的集成应用。 配置类型 选择配置的类型，可选择“模板变量”、“密码”和“证书”。 配置值
使用组合应用(流运行)或服务集成(数据API/函数API)时，需要同时开启服务集成(API管理)。 使用设备集成时，需要同时开启消息集成。 在页面配置实例的高级配置信息，完成后单击“下一步”。 表2 高级配置信息 参数 说明 网络配置 虚拟私有云 选择实例所关联的VPC和子网，VPC和子网须在准备资源中提前创建。
API。 前提条件 已获取API的调用信息，具体请参见开发准备。 已安装开发工具和Go开发语言环境，具体请参见开发准备。 已在IntelliJ IDEA中安装Go插件，如果未安装，请按照图1所示安装。 图1 安装Go插件 获取SDK 旧版界面：登录ROMA Connect实例控制台，在“服务集成
仅当“是否SASL_SSL”选择“是”时需要配置。 SASL_SSL认证所使用的用户密码，如果使用ROMA Connect的消息集成作为Kafka数据源，则密码为集成应用的Secret。 以开启SASL_SSL为例，数据源的接入配置示例如下图所示。 图1 Kafka数据源配置示例 完成数
已获取API的调用信息，具体请参见开发准备。 已安装开发工具和Python开发语言环境，具体请参见开发准备。 Python安装完成后，在命令行中使用pip安装“requests”库。 pip install requests 如果pip安装requests遇到证书错误，请下载并使用Python执
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
