创建自定义连接流
说明 若公共连接器无法满足您的业务需求，您可以在 自建连接器 页签中，选择您已创建的自定义连接器。更多信息，请参见 创建连接器。若触发器有入参配置，则先按要求填写入参，完成后单击 完成进入下一步。选择连接器执行动作，然后单击 ...
大数据计算服务MaxCompute
本文为您介绍大数据计算服务MaxCompute连接器的语法结构、WITH参数和使用示例等。背景信息 大数据计算服务MaxCompute（原名ODPS）是一种快速、完全托管的EB级数据仓库解决方案，致力于批量结构化数据的存储和计算，提供海量数据仓库的解决...
产品计费
地域 流量单价（元/GB）连接单价（元/个/月）华东1（杭州）、华东2（上海）、华北1（青岛）、华北2（北京）、华北5（呼和浩特）、华北6（乌兰察布）、华南1（深圳）、华南3（广州）、西南1（成都）1 1 云连接器费用计算示例 假设您总共购买...
本地运行和调试包含连接器的作业
相关文档 通过DataStream的方式读写数据，需要使用对应的DataStream连接器连接实时计算Flink版，DataStream连接器的使用方法和注意事项，详情请参见 JAR作业开发。Python作业的开发和调试方法，详情请参见 Python作业开发。
数据格式
本文为您介绍Flink支持的数据格式。数据格式 数据格式 支持的连接器 JSON 消息队列Kafka、Upsert Kafka、Elasticsearch、对象存储OSS，云数据库MongoDB、StarRocks。...Parquet 对象存储OSS连接器（实时计算引擎VVR 6.0.7及以上版本）
Parquet
仅对象存储OSS连接器（实时计算引擎VVR 6.0.7及以上版本）支持读取Parquet格式的数据。使用示例 利用OSS和Parquet格式创建表的示例如下。CREATE TABLE user_behavior(user_id BIGINT,item_id BIGINT,category_id BIGINT,behavior STRING,ts...
社区版CDC
说明 在使用社区版CDC连接器或者自定义连接器时，如果已经存在同名 实时计算Flink版内置连接器 或自定义连接器，请更改默认的连接器名字，避免与内置连接器冲突。其中SQL Server CDC和Db2 CDC需要修改社区默认的连接器名字并重新打包，例如...
查看监控数据
结合阿里云云监控服务，您可以查看云连接器的云监控数据，例如云连接器实例连接数、云连接器实例流入流量和流出流量等。您可以根据各监控指标来排查问题。登录 云连接器管理控制台。在 实例列表 页面，找到目标云连接器实例，在 监控 列...
连接计算组
本文为您介绍如何使用JDBC、PSQL连接计算组实例。使用JDBC连接Hologres实例 命令格式 未在连接字符串中显式指定计算组时，将使用用户默认的计算组连接实例。jdbc:postgresql:<Endpoint>:<Port>/显式指定计算组。jdbc:postgresql:/...
创建Hologres计算源
用户名、密码 填写连接计算源的用户名和密码。单击 测试连接。连接测试通过后，单击 提交。后续步骤 完成创建加速计算源后，即可为已绑定MaxCompute计算源的项目添加Hologres加速计算源或单独作为离线计算源进行使用。更多信息，请参见 ...
实时数据集成（Flink版）
实时计算Flink版服务集成物联网平台的产品属性时序表数据、产品事件表数据和自定义存储表时序数据，需要在Flink SQL开发作业中使用SQL连接器连接物联网平台数据服务中对应的时序数据表。Flink全托管产品支持您自定义连接器后上传使用，物...
创建Hologres计算源
用户名、密码 填写连接计算源的用户名和密码。单击 测试连接。连接测试通过后，单击 提交。后续步骤 完成创建加速计算源后，即可为已绑定MaxCompute计算源的项目添加Hologres加速计算源或单独作为离线计算源进行使用。更多信息，请参见 ...
创建连接器
AppFlow提供了大量的主流SaaS应用以及云产品的公共连接器。若用户有自研的应用需要被集成时，可以使用AppFlow提供的自定义连接器的功能，可以简便地将自研或采购的SaaS应用封装成AppFlow的连接器，参与到后续的连接流中。本文介绍创建...
2023-06-21版本
大数据计算服务MaxCompute DataHub连接器源表性能优化 在一定场景下提升性能幅度达到290%左右。无 表格存储Tablestore连接器支持写入时序数据 表格存储的时序模型针对时间序列数据的特点进行设计，支持写入Tablestore时序数据。无 Hive ...
2023-10-23版本
在该版本中，我们增强了Flink与阿里云各存储和计算产品之间的互操作性，对MaxCompute、StarRocks、Redis、SLS、RocketMQ连接器进行了功能增强，提高了连接器的性能和稳定性，此外，我们还提升了CTAS的易用性。平台侧主要变更有：优化了自动...
使用限制 仅Flink计算引擎VVR 2.1.5及以上版本支持Print连接器。语法结构 CREATE TABLE print_table(a INT,b varchar)WITH('connector'='print','logger'='true');您也可以基于现有的表模式使用 LIKE 子句来创建，代码示例如下。CREATE ...
Upsert Kafka
本文为您介绍如何使用Upsert Kafka连接器。背景信息 Upsert Kafka连接器支持以upsert方式从Kafka topic中读取数据并将数据写入Kafka topic。作为源表，此连接器可以将Kafka中存储的数据转换为changelog流，其中每条数据记录代表一个更新或...
API概览
本产品（云连接器/2021-05-13）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求，可通过...
IP管理
创建云连接器（Cloud Connector）实例后，您需要为云连接器实例添加一组IP地址（即物联网卡IP），用于物联网终端用户访问阿里云、指定物联网应用或IDC服务的目标地址。添加IP 为云连接器实例添加IP地址时，IP地址需要满足以下条件：IP地址...
创建和管理云连接器
您可以通过云连接器（Cloud Connector）实现物联网终端定向上云。本文为您介绍如何创建和管理云连接器实例。前提条件 您已创建了云连接器实例所属的专有网络VPC（Virtual Private Cloud），并在该VPC下对应的可用区内创建了交换机。具体...
什么是云连接器
云连接器（Cloud Connector）提供海量物联网卡一站式定向上云连接服务，即开即用，帮您实现物联网终端到阿里云之间安全、稳定、可靠的连接。云连接器通过专用APN在物联网终端和阿里云之间建立定向网络连接。您也可以通过云上组网，实现物...
管理自定义连接器
当内置的连接器无法满足需求时，您可以使用自定义连接器。本文为您介绍如何上传、使用和更新自定义连接器。注意事项 您需要根据社区定义的连接器标准开发您自定义的连接器，才能正确地被实时计算Flink版识别并使用，因此您需要明确连接器...
物联网终端定向访问阿里云物联网平台
本文指导您如何通过云连接器（Cloud Connector）使物联网终端通过私网快速、安全地访问阿里云物联网平台。前提条件 您已开通云连接器服务。如未开通，请先完成 开通服务。您已购买物联网卡。具体操作，请参见 购买物联网卡。背景信息 本文...
连接器触发事件说明
触发事件是连接器的重要功能之一，它能够作为连接流的触发节点，触发流程运行。本文介绍连接器触发事件详细信息。前提条件 已经完成连接器的创建，请参见 创建连接器。操作步骤 在连接器详情页，选择 触发事件>创建触发事件。在 创建触发...
物联网终端定向访问云服务器ECS
本文指导您如何通过云连接器（Cloud Connector）使物联网终端快速、安全地访问阿里云云服务器ECS（Elastic Compute Service）。场景示例 本文以下图场景为例。某物联网终端需要在华东1（杭州）地域实现快速访问阿里云ECS。您可以通过配置云...
购买物联网卡
使用云连接器（Cloud Connector）前您需要先购买物联网卡。本文为您介绍如何购买阿里云物联网卡。阿里云同时提供包括物联网卡和云连接器的一站式5G高速上云服务，关于如何购买物联网卡，请参见 连接管理。
DDL数据定义语句
由于文档优化调整，原DDL内容已移至连接器目录下。最新的文档内容，请参见 支持的连接器。如果您有任何关于文档的反馈，可在对应文档页面选中相关文字后，单击 文档反馈，将建议反馈给我们。
连接器鉴权方式说明
连接器鉴权指的是使用连接器的执行动作时向某个业务接口发起请求时，需要携带特定的身份标识信息，业务系统根据该信息来验证用户是否具备接口的访问权限，如果鉴权通过则能够正常访问请求的接口，否则访问失败。本文介绍连接器鉴权方式的...
管理授权规则
在 实例列表 页面，找到目标云连接器实例，在 操作 列单击 配置授权规则。在 授权规则 页签下，单击 添加规则。在 添加规则 对话框，配置以下规则信息后，单击 确定。配置 说明 规则名称 输入授权规则名称。目的 配置要访问的目标地址。...
基本概念
无 连接器（Connector）实时计算Flink版内置了丰富的连接器用于多种上下游的数据读写与同步，并支持上传和使用自定义连接器。支持的连接器 函数（Function）实时计算Flink版提供函数功能，包括内置函数和自定义函数。窗口函数概述 支持的...
Avro
支持Avro格式的连接器包括 消息队列Kafka、Upsert Kafka 和 对象存储OSS。使用示例 利用Kafka以及Avro格式构建表的示例如下。CREATE TABLE user_behavior(user_id BIGINT,item_id BIGINT,category_id BIGINT,behavior STRING,ts TIMESTAMP...
连接器执行动作说明
执行动作是连接器的重要功能之一。执行动作一般由API和其对应的出入参数构成，它能够携带输入参，调用具有业务逻辑的API，将业务处理结果通过输出参返回。执行动作能够作为连接流的执行节点，在流程运行到该节点时，完成特定的业务处理。...
授权信息
本文为您介绍 云连接器（UIS）为RAM权限策略定义的操作（Action）、资源（Resource）和条件（Condition）。云连接器（UIS）的RAM代码（RamCode）为 iotcc,fivegcc，支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持JSON格式，其...
使用限制
配额限制 资源 默认限制 申请更多配额 单个云连接器实例可配置的允许访问的目标地址（域名、目的IP地址或网段）数量 10个 提交工单 单个云连接器实例可添加物联网卡IP地址数量 100万 单账号单地域单APN下可创建的云连接器实例数量 10个 ...
日志服务SLS
DataStream API 重要 通过DataStream的方式读写数据时，则需要使用对应的DataStream连接器连接Flink，DataStream连接器设置方法请参见 DataStream连接器使用方法。Maven中央库中已经放置了 SLS DataStream连接器。读取SLS 实时计算引擎VVR...
云数据库Redis
本文为您介绍如何使用云数据库Redis连接器。背景信息 阿里云数据库Redis是兼容开源Redis协议标准、提供内存加硬盘混合存储的数据库服务，基于高可靠双机热备架构及可平滑扩展的集群架构，充分满足高吞吐、低延迟及弹性变配的业务需求，更多...
Postgres CDC（公测中）
相关文档 实时计算Flink版支持的连接器列表，请参见 支持的连接器。将数据写入PolarDB PostgreSQL版（Oracle语法兼容1.0）结果表，请参见 PolarDB PostgreSQL版（Oracle语法兼容1.0）。如果您需要读写RDS MySQL、PolarDB for MySQL或者自建...
常见问题
A：目前 BatchCompute 启动的计算节点只有内网 IP，无法连接公网，但同一个作业里的计算节点可以互相连通。Q：渲染软件需要连接lisence server怎么办？A：由于 batchcompute 启动的渲染节点是无公网 IP 的虚拟机，所以对于需要连接lisence ...
监控指标说明
pendingRecords 如果您使用的连接器汇报了pendingRecords指标，那么您可以通过该指标分析数据在外部系统的滞留数据量。Overview 指标 含义 详情 单位 支持的连接器 Num of Restarts 作业错误恢复次数。作业出错重启次数，不包含JM Failover...
常见问题诊断
您在使用视图计算时，您可查阅以下常见问题场景及解决方案。摄像头注册不成功 摄像头注册不成功请按照如下步骤排查：检查摄像头所处的网络，是否能够连通SIP服务器的IP跟端口。检查摄像头所处的网络是否有防火墙，是否允许UDP包的收发。...
- 产品推荐
- 这些文档可能帮助您