检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
连接数限制：3000 消息大小：不能超过10MB 使用SASL_SSL协议访问ROMA Connect：确保DNS具有反向解析能力，或者在hosts文件配置ROMA Connect所有节点ip和主机名映射，避免Kafka client做反向解析，阻塞连接建立。 磁盘容量申请超过业务量 *
接入SFTP数据源 接入SYBASEIQ数据源 接入HANADB数据源 接入APPCUBE数据源 接入APIC数据源 接入数据治理中心数据源 接入本地文件数据源 接入IOT数据源 接入自定义数据源 父主题： 采集技术模型
5字符。 说明： 中文字符必须为UTF-8或者unicode编码。 plugin_type 是 String 插件类型 cors：跨域资源共享 set_resp_headers：HTTP响应头管理 kafka_log：Kafka日志推送 breaker：断路器 rate_limit:
APIC是否支持多后端节点方案？ 通过负载通道支持多后端节点。一个负载通道中可以添加多个弹性云服务器。 父主题： 服务集成
83647。正整数。 type Integer 流控策略的类型 1：基础，表示绑定到流控策略的单个API流控时间内能够被调用多少次。 2：共享，表示绑定到流控策略的所有API流控时间内能够被调用多少次。 enable_adaptive_control String 是否开启动态流控：
FROM ALL_CAPTURE; 如果查询到的状态为“Aborted”，则说明CDC的出站服务器状态异常。输入以下命令后按Enter键，再输入/按Enter键执行该命令手工启动出站服务器： BEGIN DBMS_XSTREAM_ADM.START_OUTBOUND(server_name
registration; } } 运行服务器，验证代码正确性。下面示例使用JavaScript SDK中的html签名工具生成签名。 填入如图所示字段后，单击“Send request”，复制生成的curl命令，并在命令行中执行，服务器返回“Hello World!”。 如果使
equests”库。 pip install requests 如果pip安装requests遇到证书错误，请下载并使用Python执行此文件，升级pip，然后再执行以上命令安装。 已在IntelliJ IDEA中安装Python插件，如果未安装，请按照图1所示安装。 图1 安装Python插件
值）。 最小长度：1 最大长度：100000 表3 FormData参数 参数 是否必选 参数类型 描述 file 否 File 上传产品文件(.csv格式)，参考《使用指南》：“用户指南 > 使用指南 > 设备集成指导 > 产品管理 > 导入导出产品”中的csv格式文档示例。 响应参数
jar：运行的主程序。 在设备详情页的“基本信息”页签中拷贝“边缘连接配置(IPV4)”到config目录下的mqtt.properties文件中。 执行启动脚本。 Windows下执行bin/windows/start.bat。 Linux下执行bin/linux/start.sh。
83647。正整数。 type Integer 流控策略的类型 1：基础，表示绑定到流控策略的单个API流控时间内能够被调用多少次。 2：共享，表示绑定到流控策略的所有API流控时间内能够被调用多少次。 enable_adaptive_control String 是否开启动态流控：
的命名规则填写流控策略名称，方便您快速识别和查找。 类型 选择流控策略的类型。 基础流控：流控策略绑定的API，各自消费该策略的流控值。 共享流控：流控策略绑定的所有API，共同消费该策略的流控值。 时长 填写流量限制的时长，单位可选择“秒”、“分钟”、“小时”和“天”，需与流量限制参数配合使用。
、低延迟的平台，可以处理大量的实时数据流。Kafka主要由三个部分组成：生产者、消费者和代理服务器。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是Kafka集群中的核心组件，负责处理消息的存储和转发。Kafka的主要优点是可扩展性、高吞
-255字符 说明： 中文字符必须为UTF-8或者unicode编码。 plugin_type String 插件类型 cors：跨域资源共享 set_resp_headers：HTTP响应头管理 kafka_log：Kafka日志推送 breaker：断路器 rate_limit:
的命名规则填写流控策略名称，方便您快速识别和查找。 类型 选择流控策略的类型。 基础流控：流控策略绑定的API，各自消费该策略的流控值。 共享流控：流控策略绑定的所有API，共同消费该策略的流控值。 时长 填写流量控制的统计时长，单位可选择“秒”、“分钟”、“小时”和“天”，需与流量限制参数配合使用。
在每次任务执行过程中，如果源端的某些数据符合集成条件，但因为网络抖动或数据转换异常等原因，无法顺利集成到目标端数据源，则ROMA Connect可以将这些数据以文本文件的形式存储在OBS中。 如果需要配置“异常数据存储”，请展开“异常数据存储”模块参照表1进行配置，如果不需要配置，请将“异常数据存储”模块折叠，否则影响任务保存。
、低延迟的平台，可以处理大量的实时数据流。Kafka主要由三个部分组成：生产者、消费者和代理服务器。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是Kafka集群中的核心组件，负责处理消息的存储和转发。Kafka的主要优点是可扩展性、高吞
execute(data) { var plainText = "plainText"; //加解密用的密钥硬编码到代码中有较大的安全风险，建议在配置文件中存放，本示例以在自定义后端的配置管理中配置的secretKey为例进行说明 var secretKey = "#{secretKey}";
后端超时时间设置不合理。 当后端服务没有在设置的后端超时时间内返回时，API网关提示后端服务调用失败。 如果“后端服务地址”在ECS（Elastic Cloud Server），ECS的安全组无法被外部访问。 解决方案 在编辑API中修改后端服务地址。 在编辑API中增加后端超时时间。 确认业务的出入端口和协议都设置正确。
test.js 测试用例 js\hmac-sha256.js 依赖库 licenses\license-crypto-js 第三方库license文件 licenses\license-node 创建工程 打开IntelliJ IDEA，选择菜单“File > New > Project”。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
