Connector安装及使用
{"name":"oss_test","config":{"name":"oss_test","connector.class":"io.confluent.connect.s3.S3SinkConnector","tasks.max":"1","key.converter":"org.apache.kafka.connect.storage.StringConverter","value.converter":"org.apache....
管理Kafka自定义连接器
参数 说明 示例 Kafka Connect插件 事件总线EventBridge 支持将包含Kafka Connect配置信息的.zip文件通过 本地上传 或者 OSS引用 的方式导入控制台。默认选择 OSS引用。OSS引用 Bucket存储桶 选择包含.zip文件的存储空间Bucket。更多信息，...
运行日志
远程配置功能的例程运行后，您可以在设备端 和物联网平台 查看日志信息。前提条件 已配置C Link SDK的远程功能例程，详细信息，请参见 使用示例。设备端日志 您可以在设备端查看运行结果。连接日志：出现如下日志，表示设备与物联网平台...
使用SYS_CONNECT_BY_PATH检索路径
SYS_CONNECT_BY_PATH是一个函数，它在分层查询中用于检索在当前节点和根节点之间出现的指定列的值。函数的特征为：SYS_CONNECT_BY_PATH(column,delimiter)该函数采用两个参数：column 是位于分层查询中指定的表中且调用该函数的列的名称。...
alicloud_express_connect_vbr_pconn_associations
This data source provides Express Connect Vbr Pconn Association available to the user.->NOTE:Available in 1.196.0+Example Usage data"alicloud_express_connect_vbr_pconn_associations""default"{ ids=["example_id"]vbr_id=...
使用Kafka Connect将MySQL数据同步至云消息队列 Kafka...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
自有模组驱动接入：STM32+合宙Air724
本文介绍如何快速移植C语言Link SDK，将搭载MCU+蜂窝模组的设备接入阿里云物联网平台。背景信息 无法直接连网的设备，外接MCU+蜂窝模组后，MCU通过AT指令控制蜂窝模组，设备即可实现连网。通过移植阿里云物联网平台提供的C Link SDK，设备...
alicloud_express_connect_vbr_pconn_association
Provides a Express Connect Vbr Pconn Association resource.For information about Express Connect Vbr Pconn Association and how to use it,see What is Vbr Pconn Association.->NOTE:Available since v1.196.0.Example Usage Basic ...
alicloud_express_connect_virtual_border_routers
This data source provides the Express Connect Virtual Border Routers of the current Alibaba Cloud user.->NOTE:Available in v1.134.0+.Example Usage Basic Usage data"alicloud_express_connect_virtual_border_routers""ids"{} ...
使用CONNECT_BY_ROOT检索根节点
CONNECT_BY_ROOT 是一元运算符，可用于限定列，以便根据当前行返回被视为根节点的行的列值。一元运算符对单个操作数执行运算；就 CONNECT_BY_ROOT 而言，该操作数是 CONNECT_BY_ROOT 关键字后面的列名称。在 SELECT 列表的上下文中，...
Quick BI自助取数失败报错："connect timed out
问题描述 Quick BI自助取数失败报错："connect timed out。问题原因 自助取数得机器无法连接该地址导致的。解决方案 添加下白名单，在数据源窗口复制完整的白名单列表进行添加。适用于 Quick BI 专业版
同步数据到数据表
9092#unique name for the cluster,used in forming the Connect cluster group.Note that this must not conflict with consumer group IDs group.id=connect-cluster#The converters specify the format of data in Kafka and how to ...
alicloud_express_connect_physical_connection
Provides a Express Connect Physical Connection resource.For information about Express Connect Physical Connection and how to use it,see What is Physical Connection.->NOTE:Available since v1.132.0.Example Usage Basic Usage ...
Quick BI数据源链接测试报错“connect timed out”
问题描述 Quick BI数据源链接测试报错“connect timed out”。问题原因 数据源白名单没有加全。解决方案 检查白名单添加情况，补充完整的白名单。适用于 Quick BI 公共云4.2
Quick BI自助取数任务报错“Connect to[IP地址]failed...
问题描述 Quick BI自助取数任务报错“Connect to[IP地址]failed，Connection refused”。问题原因 此问题一般出现在独立部署客户环境，问题原因是自助取数所部署的机器在连接用户取数对应的数据源时不能连通，原因可能为：1.自助取数机器IP...
Connector使用案例
key.converter":"org.apache.kafka.connect.storage.StringConverter","value.converter":"org.apache.kafka.connect.storage.StringConverter","topics":"redis-connect-topic","redis.uri":"redis:/r-xxxxxxxxxxxx.redis.rds.aliyuncs....
通过Kafka导入数据
db key.converter=org.apache.kafka.connect.storage.StringConverter value.converter=org.apache.kafka.connect.json.JsonConverter 启动Standalone$KAFKA_HOME/bin/connect-standalone.sh-daemon$KAFKA_HOME/config/connect-standalone....
alicloud_express_connect_virtual_border_router
Provides a Express Connect Virtual Border Router resource.For information about Express Connect Virtual Border Router and how to use it,see What is Virtual Border Router.->NOTE:Available since v1.134.0.Example Usage Basic ...
高速通道服务等级协议
高速通道（Express Connect）服务等级协议，请参见 高速通道服务等级协议。
使用Kafka Connect将SQL Server数据同步至云消息队列 ...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
管理Kafka自定义连接器
创建流程 创建步骤 云消息队列 Kafka 版 支持创建消息流入任务将其他资源服务通过Kafka Connect投递到Kafka，也可以创建消息流出任务将Kafka资源通过Kafka Connect投递到其他资源服务。本文以创建消息流入（Source）任务为例。登录 云消息...
回调接口
回调参数 类型 说明 bizName String 对应 Connect 的 biz_name appId String 对应 Connect 的 appId uid String 对应 Connect 的 UID workspaceId String 对应 Connect 的 workspaceId OnError(data)错误信息回调通知。回调参数 类型 说明 ...
TSDBClientFactory
从类继承的方法 java.lang.Object clone,equals,finalize,getClass,hashCode,notify,notifyAll,toString,wait 构造器详细资料 TSDBClientFactory public TSDBClientFactory()方法详细资料 connect publicstatic TSDB connect(String host,...
使用RabbitMQ Connector同步RabbitMQ数据
Kafka Connect Worker 配置 自动创建Kafka Connect Worker依赖资源 建议勾选此项，此时会在选择的Kafka实例中自动创建Kafka Connect运行所需的一些Internal Topic以及ConsumerGroup，并将这些必填配置自动填入配置框中，包括以下配置项：...
运行日志
MQTT协议下载仅含单个升级文件的升级包的OTA例程运行后，您可以在设备端和物联网平台查看日志信息。前提条件 已配置OTA升级例程./demos/mota_basic_demo.c，详细信息，请参见 示例代码说明。设备端日志 您可以在设备端查看运行结果。连接...
使用RabbitMQ Connector同步RabbitMQ数据
Kafka Connect Worker 配置 自动创建Kafka Connect Worker依赖资源 建议勾选此项，此时会在选择的Kafka实例中自动创建Kafka Connect运行所需的一些Internal Topic以及ConsumerGroup，并将这些必填配置自动填入配置框中，包括以下配置项：...
基于IPv6的MQTT连接通信
您可通过MQTT直连方式将设备接入物联网平台。使用限制 目前，仅华东2（上海）地域支持基于IPv6协议的MQTT通道。设备端接入物联网平台 下载用于TLS加密的 根证书。根证书使用方法，请参见 CA Certificates。开发设备端，配置MQTT连接。建议...
java_net_SocketException
172)at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)at java.net.Socket.connect(Socket.java:579)at java.net.Socket.connect(Socket.java:528)at java.net.Socket.(Socket.java:425)at java.net.Socket.(Socket.java:208...
上传资源至OSS时出现“Connect to oss failed:[Errno-...
问题描述 上传资源至OSS时出现“Connect to oss failed:[Errno-2]Name or service not known”的报错。问题原因 此报错目前有两种原因：上传的EndPoint地址输入错误。服务器DNS无法解析。解决方法 检查EndPoint域名地址是否正确。更多信息...
alicloud_express_connect_virtual_physical_...
This data source provides Express Connect Virtual Physical Connection available to the user.->NOTE:Available in 1.196.0+Example Usage data"alicloud_express_connect_virtual_physical_connections""default"{ ids=["${alicloud_...
alicloud_express_connect_virtual_physical_...
Provides a Express Connect Virtual Physical Connection resource.For information about Express Connect Virtual Physical Connection and how to use it,see What is Virtual Physical Connection.->NOTE:Available since v1.196.0....
账号权限列表
public db_datareader db_datawriter Server级别权限 CONNECT SQL ALTER ANY LOGIN ALTER ANY LINKED SERVER ALTER ANY CONNECTION ALTER TRACE VIEW ANY DATABASE VIEW SERVER STATE ALTER SERVER STATE Database级别权限 CONNECT ...
同步数据到时序表
您可以使用kafka-connect-tablestore包将Kafka中数据写入Tablestore的时序表中。本文主要介绍了如何配置Kafka写入时序数据。前提条件 已安装Kafka，并且已启动ZooKeeper和Kafka。更多信息，请参见 Kafka官方文档。已开通表格存储服务，创建...
运行日志
[1579511737.377][LK-0313]MQTT user calls aiot_mqtt_connect api,connect[1579511737.377][LK-0317]LightSwitch&a18wP*[1579511737.377][LK-0318]779ACA0181ED1C0BD4B1BA7A347C9B172E27EAAB4AA18FC1F9FAD4CED1*[1579511737.377][LK-0319]...
Quick BI公网添加Clickhouse提示“connect timed out...
问题描述 Quick BI公网添加Clickhouse已经添加了对应的白名单还是提示“connect timed out”。错误信息如下：问题原因 Clickhouse数据源添加了白名单过长导致Clickhouse的安全组没有自动识别到，从而导致的端口不通。解决方案 在白名单添加...
00257:archiver error.Connect internal only,...
问题描述 从Oracle向ODPS通过管道任务同步数据，管道任务报错“ORA-00257:archiver error.Connect internal only,until freed”。问题原因 由于Oracle数据库归档日志太多，占用了较多的硬盘剩余空间导致该问题。解决方案 通过在Oracle数据...
使用MirrorMaker 2（Dedicated）跨集群同步数据
see org.apache.kafka.clients.consumer.ConsumerConfig for more details#Sample MirrorMaker 2.0 top-level configuration file#Run with./bin/connect-mirror-maker.sh connect-mirror-maker.properties#specify any number of cluster ...
示例一：MQTT多文件上传
本文以C Link SDK中的Demo文件./demos/mqtt_upload_basic_demo.c 为例，介绍如何调用Link SDK的API，帮助设备基于MQTT协议的连接，将文件上传至物联网平台，以减少硬件资源的开销，并降低开发成本。背景信息 文件上传功能的更多信息，请...
层次查询函数
SYS_CONNECT_BY_PATH 描述 该函数仅在层次查询中有效。它返回列值从根到节点的路径，对于 CONNECT BY 条件返回的每一行，列值用 char 分隔。语法 SYS_CONNECT_BY_PATH(column,char)参数 参数 说明 column 可以为 char、VARCHAR2、NCHAR 或 ...
SMTP发信报错：Could not connect to SMTP host
问题描述 连接SMTP服务器发送邮件，出现错误提示，如“Could not connect to SMTP host”。问题原因 出现这种报错，是因为程序在发送邮件的最开始阶段，连接邮箱服务器时就出现了问题，此时邮箱服务端没有入信记录，不会有相关发信日志，...
- 产品推荐
- 这些文档可能帮助您