简介
API 应用程序编程接口 用户开放API，在API网关录入API，以提供接口的方式对外提供服务或者数据。Group API Group API分组 一组API。用户开放API，首先需要创建API分组 每个API分组拥有一个二级域名，两个Stage 用户需要将已经备案且解析至...
基础术语
中文 释义 API 应用程序编程接口，是一些预先定义的函数，或指软件系统不同组成部分衔接的约定。API 分组 用于将 API 进行逻辑的分组，同个分组下的 API 使用相同的分组标识做隔离。分组标识 是网关全局的唯一标识，用于定位在访问的 API。...
使用MirrorMaker 2（Dedicated）跨集群同步数据
当其中一个集群不可用时，可以将上面的应用程序切换到另一个集群，从而实现异地容灾功能。数据迁移场景：在业务上云、混合云、集群升级等场景，存在数据从旧集群迁移到新集群的需求。此时，您可以使用MM2实现新旧数据的迁移，保证业务的...
快速开始使用EMR Kafka
本文为您介绍如何创建E-MapReduce（简称EMR）Kafka集群、Kafka访问的设置，使用Kafka Topic和Kafka Connect服务，帮您快速了解和上手使用EMR Kafka。创建EMR Kafka集群 该部分内容为您简单介绍如何创建Kafka集群，更详细的创建操作，请参见...
ConnectRouterInterface-由发起端路由器接口向接收端...
400 IncorrectOppositeInterfaceInfo Cannot connect on the same router 不允许连接相同的路由器。400 IncorrectOppositeInterfaceInfo The opposite RouterInterface information specified by OppositeInterfaceId/OppositeRouterId/...
ConnectRouterInterface-由发起端路由器接口向接收端...
400 IncorrectOppositeInterfaceInfo Cannot connect on the same router 不允许连接相同的路由器。400 IncorrectOppositeInterfaceInfo The opposite RouterInterface information specified by OppositeInterfaceId/OppositeRouterId/...
RRPC能力
def on_connect(self,session_flag,rc,userdata):print("on_connect:%d,rc:%d,userdata:"%(session_flag,rc))self.linkkit.subscribe_rrpc_topic("/${YourProductKey}/${YourDeviceName}/user/get")其中Topic：/${YourProductKey}/${...
认证与连接
示例代码如下：def on_connect(session_flag,rc,userdata):print("on_connect:%d,rc:%d,userdata:"%(session_flag,rc))pass def on_disconnect(rc,userdata):print("on_disconnect:rc:%d,userdata:"%rc)lk.on_connect=on_connect lk.on_...
ProtoBuf数据解析示例
buf=bytearray(os.path.getsize(filename))with open(filename,'rb')as f:f.readinto(buf)return buf lk.on_device_dynamic_register=on_device_dynamic_register lk.on_connect=on_connect lk.on_disconnect=on_disconnect lk.on_topic_...
Paho-MQTT Python接入示例
else:print("connect failed.error code is:"+str(rc))def connect_mqtt():client.on_connect=on_connect client.connect(host,port,keepAlive)return client 调用Publish接口发布消息。您需指定发布消息的目标Topic和消息payload。def ...
使用MirrorMaker 2（on Connect）跨集群同步数据
本文通过示例为您介绍如何使用MirrorMaker 2（简称MM2）on Kafka Connect跨集群同步数据。背景信息 使用场景 Kafka MM2适用于下列场景：远程数据同步：通过MM2，Kafka数据可以在不同地域的集群进行传输复制。灾备场景：通过MM2，可以构建...
Location-定位服务组件
device.on('connect',()=>{ console.log('connected');setInterval(()=>{ btsInfo=loc.getAccessedLbsInfo();nearbtsInfo=loc.getNearLbsInfo();var lbsMessage=JSON.stringify({ cdma:'0',bts:btsInfo,nearbts:btsInfo })console.log('lbs...
认证与连接
/监听connect事件 device.on('connect',()=>{/将${productKey}和${deviceName}修改为实际值 device.subscribe(`/${productKey}/${deviceName}/user/get`);console.log('connect successfully!');device.publish(`/${productKey}/${...
错误代码表
{Reason} B403MO 403 Api Market Subscription overdue API提供商欠费，请联系服务商处理 B403MQ 403 Api Market Subscription quota exhausted 购买的云市场API配额已耗尽，请续费次数 B403ME 403 Api Market Subscription expired API...
使用国密算法接入云网关
操作步骤 如下功能时序图，以设备的应用程序 demos/device_gmssl_demo.c 为例，介绍国密接入的使用流程。步骤1：设备初始化 添加头文件#include"aiot_device_api.h"创建设备句柄 void*device_client=aiot_device_create(product_key,device...
使用Python Client提交Presto作业
本文为您介绍如何使用Python Client编程的方式访问Trino On ACK服务并执行查询操作。背景信息 Trino JDBC使用和相关参数的更多信息，请参见 trino-python-client。前提条件 已在E-MapReduce on ACK控制台创建Presto集群，详情请参见 快速...
TCP
tcpClient.on('connect',function(){ console.log('tcp client connected');});tcpClient.on('disconnect',function(){ console.log('tcp client disconnected');});tcpClient.on('error',function(err){ console.log('tcp client error:'+...
Node.js SDK收发消息
producer.on('ready',function(){ connected=true console.log("connect ok")});producer.on("disconnected",function(){ connected=false;producer.connect();})producer.on('event.log',function(event){ console.log("event.log",event)...
NetWork
返回 属性 类型 描述 connect String 网络已连接，并且获取到IP地址。disconnect String 网络断开状态。getInfo()获取网络详细信息。入参 无。返回 Object 类型，其参数有：属性 类型 描述 netInfo Object 网络信息，只适用于Wi-Fi和以太...
同步数据到数据表
9092#The converters specify the format of data in Kafka and how to translate it into Connect data.Every Connect user will#need to configure these based on the format they want their data in when loaded from or stored into ...
使用MongoDB Connector连接MongoDB数据库
options]]database=testDatabase delete.on.null.values=false key.converter=org.apache.kafka.connect.storage.StringConverter key.converter.schemas.enable=false max.batch.size=0 rate.limiting.every.n=0 rate.limiting.timeout=0 ...
使用MongoDB Connector连接MongoDB数据库
options]]database=testDatabase delete.on.null.values=false key.converter=org.apache.kafka.connect.storage.StringConverter key.converter.schemas.enable=false max.batch.size=0 rate.limiting.every.n=0 rate.limiting.timeout=0 ...
使用RabbitMQ Connector同步RabbitMQ数据
Please check the error log/opt/kafka/logs/connect.log on sae application to find out the reason why kafka connect exited and update the event streaming with valid arguments to solve it.解决方法：由于状态获取可能会有延迟，...
使用RabbitMQ Connector同步RabbitMQ数据
Please check the error log/opt/kafka/logs/connect.log on sae application to find out the reason why kafka connect exited and update the event streaming with valid arguments to solve it.解决方法：由于状态获取可能会有延迟，...
使用JDBC Connector同步MySQL数据
Kafka Connect Worker 配置 自动创建Kafka Connect Worker依赖资源 建议勾选此项，此时会在选择的Kafka实例中自动创建Kafka Connect运行所需的一些Internal Topic以及ConsumerGroup，并将这些必填配置自动填入配置框中，包括以下配置项：...
使用JDBC Connector同步MySQL数据
Kafka Connect Worker 配置 自动创建Kafka Connect Worker依赖资源 建议勾选此项，此时会在选择的Kafka实例中自动创建Kafka Connect运行所需的一些Internal Topic以及ConsumerGroup，并将这些必填配置自动填入配置框中，包括以下配置项：...
自建Oracle间的数据迁移
通过增量数据迁移可以实现在应用不停服的情况下，平滑地完成Oracle数据库的迁移。数据库账号的权限要求 迁移数据源 结构迁移 全量迁移 增量数据迁移 源Oracle数据库 Schema的Owner权限 Schema的Owner权限 DBA 目标Oracle数据库 Schema的...
从自建Oracle迁移至阿里云RDS MySQL
DTS支持结构迁移、全量数据迁移以及增量数据迁移，同时使用这三种迁移类型可以实现在本地应用不停服的情况下，平滑地完成Oracle数据库的数据迁移。前提条件 自建Oracle数据库的版本为9i、10g、11g、12c、18c或19c版本。自建Oracle数据库已...
从自建Oracle同步至DataHub
v$active_instances privileges grant select on v_$active_instances to rdsdt_dtsacct;v$instance privileges grant select on v_$instance to rdsdt_dtsacct;v$logmnr_contents privileges grant select on v_$logmnr_contents to rdsdt...
从自建Oracle迁移至PolarDB PostgreSQL版（兼容Oracle...
PolarDB是阿里云自研的下一代关系型云数据库，有三个独立的引擎，分别可以100%兼容MySQL、100%兼容PostgreSQL、高度兼容Oracle语法，适用于企业多样化的数据库应用场景。通过使用数据传输服务DTS（Data Transmission Service），您可以将自...
从自建Oracle迁移至云原生数据仓库AnalyticDB ...
在增量数据迁移阶段，DTS支持同步的SQL语句如下：DML：INSERT、UPDATE、DELETE DDL：ADD COLUMN 通过增量数据迁移可以实现在自建应用不停服的情况下，平滑地完成数据迁移。数据库账号所需权限 数据库 结构迁移 全量迁移 增量数据迁移 自建...
从自建Oracle迁移至云原生数据仓库AnalyticDB ...
在增量数据迁移阶段，DTS支持同步的SQL语句如下：DML：INSERT、UPDATE、DELETE DDL：ADD COLUMN 通过增量数据迁移可以实现在自建应用不停服的情况下，平滑地完成数据迁移。数据库账号所需权限 数据库 结构迁移 全量迁移 增量数据迁移 自建...
使用Debezium将PostgreSQL数据同步至消息队列Kafka版
Please check the error log/opt/kafka/logs/connect.log on sae application to find out the reason why kafka connect exited and update the event streaming with valid arguments to solve it.解决方法：由于状态获取可能会有延迟，...
使用Debezium将PostgreSQL数据同步至消息队列Kafka版
Please check the error log/opt/kafka/logs/connect.log on sae application to find out the reason why kafka connect exited and update the event streaming with valid arguments to solve it.解决方法：由于状态获取可能会有延迟，...
使用Debezium将MySQL数据同步至云消息队列 Kafka 版
Please check the error log/opt/kafka/logs/connect.log on sae application to find out the reason why kafka connect exited and update the event streaming with valid arguments to solve it.解决方法：由于状态获取可能会有延迟，...
DescribeInstances-查询实例列表
调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中使用，用来给RAM用户或RAM...
Main Thread Checker:UI API called on a background ...
问题详述 Main Thread Checker:UI API called on a background thread 具体事例：解决方法 请 pod update 一下，确定 AlicloudUT 版本为 5.2.0.12，已经修复该 UI 卡顿问题。如还有该问题出现，请参考下面的排查步骤：请检查工程中，是否在...
使用Kafka Connect将MySQL数据同步至云消息队列 Kafka...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
使用Kafka Connect将SQL Server数据同步至云消息队列 ...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
文件上传
[inf]on_frame_recv_callback(196):on_frame_recv_callback,type=8[inf]on_frame_recv_callback(197):on_frame_recv_callback,stream_id=3[inf]on_frame_recv_callback(205):stream user data is not exist[inf]on_begin_headers_callback...
- 产品推荐
- 这些文档可能帮助您