常见问题
如果您有配置多Hive MetaStore、多MySQL的需求，或默认提供的连接器不包含您想要使用的服务时，您可以使用EMR Trino提供的5个占位连接器，即connector1~connector5，您可以选择其中任意一个，将其 connector.name 配置为hive或您所需要的...
配置连接器
EMR Trino内置连接器 EMR Trino默认提供以下几种开箱即用的内置连接器。连接器 功能 对应文档 Hive 使用Hive连接器可以查询存储在Hive数据仓库中的数据。Hive连接器 Kudu 使用Kudu连接器可以查询、插入和删除存储在Kudu里的数据。Kudu连接...
配置连接器
EMR Presto内置连接器 EMR Presto默认提供了开箱即用的内置连接器，详情信息如下表。连接器 功能 对应文档 hive 使用Hive连接器可以查询存储在Hive数据仓库中的数据。Hive连接器 kudu 使用Kudu连接器可以查询、插入和删除存储在Kudu里的...
配置连接器
EMR Presto内置连接器 EMR Presto默认提供以下几种开箱即用的内置连接器。连接器 功能 hive 使用Hive连接器可以查询存储在Hive数据仓库中的数据。kudu 使用Kudu连接器可以查询、插入和删除存储在Kudu里的数据。mysql 使用MySQL连接器可以在...
Datagen
如果您在开发或测试时，需要使用一些测试数据来快速验证业务逻辑，您可以使用Datagen连接器来生成随机数据。Datagen支持计算列语法 Computed Column syntax，使它可以灵活地生成数据。Datagen连接器支持的信息如下。类别 详情 支持类型 源...
以太网接口无法接通
说明 10/100/1000 Mbps电接口采用RJ45连接器，接口线缆为5类或5类以上双绞线，此类双绞线最大传输距离为100米。如果线缆长度大于100米可以采用如下方式：缩短设备之间距离以缩短双绞线长度。如果不能改变设备之间的距离，设备之间可以通过...
查看监控数据
结合阿里云云监控服务，您可以查看云连接器的云监控数据，例如云连接器实例连接数、云连接器实例流入流量和流出流量等。您可以根据各监控指标来排查问题。登录 云连接器管理控制台。在 实例列表 页面，找到目标云连接器实例，在 监控 列...
Iceberg连接器
Iceberg是一种开放的数据湖表格式，使用Iceberg连接器可以用来查询Iceberg格式的数据文件。背景信息 Iceberg的详细信息，请参见 Iceberg概述。本文为您介绍Iceberg连接器相关的内容和操作，具体如下：配置Iceberg连接器 示例：查询Iceberg...
以太网接口频繁Up/Down
说明 10/100/1000M电接口采用RJ45连接器，接口线缆为5类或5类以上双绞线，最大传输距离100m。如果线缆长度大于100m可以采用如下方式：缩短设备间距离，以缩短双绞线长度。如果不能改变设备间的距离，设备之间可以通过中继器、HUB或交换机...
管理自定义连接器
当内置的连接器无法满足需求时，您可以使用自定义连接器。本文为您介绍如何上传、使用和更新自定义连接器。注意事项 您需要根据社区定义的连接器标准开发您自定义的连接器，才能正确地被实时计算Flink版识别并使用，因此您需要明确连接器...
创建连接器
AppFlow提供了大量的主流SaaS应用以及云产品的公共连接器。若用户有自研的应用需要被集成时，可以使用AppFlow提供的自定义连接器的功能，可以简便地将自研或采购的SaaS应用封装成AppFlow的连接器，参与到后续的连接流中。本文介绍创建...
授权信息
操作 API 访问级别 资源类型 条件关键字 关联操作 暂无数据 资源（Resource）下表是 云连接器（UIS）定义的资源，这些资源可以在RAM权限策略语句的 Resource 元素中使用，用来授予对该资源执行具体操作的权限。其中，资源ARN是资源在阿里云...
C3P0 连接池连接 OceanBase 数据库示例程序
本文将介绍如何使用 C3P0 连接池、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入、删除、更新和查询数据等。点击下载 c3p0-mysql-jdbc 示例工程 前提条件 您已安装 OceanBase 数据库...
常见问题
本文介绍云连接器（Cloud Connector）相关常见问题。什么是物联网？什么是云连接器？为什么选择云连接器？云连接器的使用场景及操作指导？使用云连接器有哪些注意事项？什么是物联网？物联网IoT（Internet of Things）是基于互联网、传统...
选择合适的网络转发组件
选择合适的网络 转发 组件 SASE 支持的网络 转发 组件 SASE连接器 如果业务组网没有部署阿里云VBR、CCN、VPN网关，您可以使用 SASE 连接器。您需要创建 SASE 连接器，并将连接器部署到您的业务资源所在的线下IDC机房，或业务资源所在的其他...
数据访问代理连接器概述
数据访问代理连接器提供 SecuritySpec 接口来集成用户自定义的加解密算法 JAR 包，从而实现对自定义加解密算法的支持。SQL 链路追踪 将 traceId 通过 MySQL 的自定义 HINT 语句传给数据访问代理服务器，从而打通应用到服务器的链路，输出 ...
连接器触发事件说明
触发事件是连接器的重要功能之一，它能够作为连接流的触发节点，触发流程运行。本文介绍连接器触发事件详细信息。前提条件 已经完成连接器的创建，请参见 创建连接器。操作步骤 在连接器详情页，选择 触发事件>创建触发事件。在 创建触发...
DataStream连接器设置方法
您可以通过以下任何一种方式来使用连接器：（推荐）上传连接器JAR包到实时计算控制台后，填写配置信息 直接将连接器作为项目依赖打进作业JAR包 重要 请使用我们在 支持的连接器 中指明提供DataStream API的连接器。如果某个连接器未注明...
Blackhole
本文为您介绍如何使用Blackhole连接器。背景信息 Blackhole是主要用于调试的连接器，允许接收所有的输入记录。如果您在注册其他类型的连接器结果表时报错，但不确定是系统问题还是结果表WITH参数错误，您可以将WITH参数修改为 'connector'=...
2023-06-21版本
CREATE TABLE AS（CTAS）语句 MySQL连接器结果表和维表能力增强 通过此增强，从此版本起，我们推荐您将之前使用阿里云RDS连接器的作业逐步迁移至MySQL连接器。MySQL MySQL源表CDC增量读取支持无主键的表 此次更新可以让更多种类的MySQL表...
JAR作业开发
您可以使用以下任意一种方式来使用连接器：（推荐）上传连接器Uber JAR包到Flink开发控制台，DataStream作业通过provided引用 直接将连接器作为项目依赖打进作业JAR包 重要 请使用我们在 支持的连接器 中指明提供DataStream API的连接器。...
本地运行和调试包含连接器的作业
本文为您介绍如何在开发者本地环境中运行和调试包含阿里云实时计算Flink版连接器的作业，以便快速验证代码的正确性，快速定位和解决问题，并节省云上成本。背景信息 当您在Inteillij IDEA中运行和调试Flink作业，如果其包含了阿里云实时...
MySQL连接器
使用MySQL连接器能够让您在外部MySQL实例中查询和创建表。该连接器可以用于不同系统（例如，MySQL和Hive），或者两个不同MySQL实例间的数据进行JOIN操作。背景信息 本文为您介绍MySQL连接器相关的内容和操作，具体如下：配置MySQL连接器 ...
ListConnectionPoolIps-查询连接地址池中的IP地址状态
192.168.XX.XX Status string IP 地址状态，仅取值 activated，表示已激活，IP 地址和云连接器绑定完成。activated 示例 正常返回示例 JSON 格式 {"RequestId":"CEF72CEB-54B6-4AE8-B225-F876FF7BA984","TotalCount":2,"NextToken":"caeba0...
连接器鉴权方式说明
连接器鉴权指的是使用连接器的执行动作时向某个业务接口发起请求时，需要携带特定的身份标识信息，业务系统根据该信息来验证用户是否具备接口的访问权限，如果鉴权通过则能够正常访问请求的接口，否则访问失败。本文介绍连接器鉴权方式的...
连接器执行动作说明
执行动作是连接器的重要功能之一。执行动作一般由API和其对应的出入参数构成，它能够携带输入参，调用具有业务逻辑的API，将业务处理结果通过输出参返回。执行动作能够作为连接流的执行节点，在流程运行到该节点时，完成特定的业务处理。...
使用场景和主要概念
连接器由动作、连接配置和节点配置构成：同一连接器支持多个动作（如数据库连接器的查询、插入动作）。连接配置是被集成应用的通用配置（如调用域名、超时时间等）。节点配置是在集成流中使用该连接器节点时的各种具体配置（如HTTP接口的...
本文为您介绍如何使用Print连接器。背景信息 Print是用于调试的连接器，允许接收并打印一定数量的输入记录。如果您想观察SQL的中间结果，或者观察最终输出结果，可以给SQL语句添加Print结果表，即将WITH参数修改为 'connector'='print' 后...
管理Kafka自定义连接器
本文介绍如何创建、查看、编辑、删除Kafka自定义连接器任务。支持的地域 目前支持创建Kafka自定义连接器任务的地域有：华东1（杭州）、华东2（上海）、华北2（北京）、华北3（张家口）、华南1（深圳）、中国香港、美国（硅谷）、新加坡。...
VMware虚拟机无代理迁移
说明 若没有适合您的VMware无代理连接器，请在 迁移源类型 中选择 物理机/虚拟机/云服务器，然后选择以下任一方式导入迁移源：通过控制台自动导入迁移源 通过命令行一键导入迁移源 通过SMC客户端导入迁移源 部署VMware无代理连接器 在...
管理Kafka自定义连接器
本文介绍如何创建、查看、编辑、删除Kafka自定义连接器任务。支持的地域 目前支持创建Kafka自定义连接器任务的地域有：华东1（杭州）、华东2（上海）、华北2（北京）、华北3（张家口）、华南1（深圳）、中国香港、美国（硅谷）、新加坡。...
GetIoTCloudConnectorAccessLog-获取指定云连接器访问...
获取指定云连接器访问日志状态信息。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句...
使用限制
购买光口，线路接入类型必须是光纤，请要求运营商用光纤接入阿里云的专线端口。购买电口，线路接入类型必须是电路，请要求运营商用电路接入阿里云的专线端口。阿里机房不支持托管任何光电转换设备，施工方携带的任何光电设备无法安装到阿里...
EnableIoTCloudConnectorAccessLog-开启访问日志功能
指定云连接器开启访问日志功能。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 ...
OceanBase（公测中）
本文为您介绍如何使用OceanBase连接器。背景信息 OceanBase数据库是一款原生分布式的HTAP数据库管理系统，详情请参见 OceanBase官网。为了降低您从MySQL数据库或Oracle数据库迁移到OceanBase数据库时引发的业务系统改造成本，OceanBase数据...
ListRegions-查询云连接器支持的地域列表
查询云连接器支持的地域列表。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 ...
Delta连接器
EMR Trino提供了独立的Delta连接器，在E-MapReduce集群上支持了较为完整的数据湖特性并进行了特性扩展。背景信息 Delta Lake是DataBricks公司推出的一种数据湖方案，以数据为中心，围绕数据流走向推出了一系列功能特性，详情请参见 Delta ...
Superset连接数据湖分析
大多数BI工具可以使用MySQL连接器直接连接DLA，由于Superset对于表的定义语句校验严格，同时DLA的建表语句与MySQL的建表语句存在差别，这导致Superset不能够直接连接DLA，但是我们支持一种兼容模式，可以通过修改用户名的方法来连接DLA。...
ListConnectionPools-查询云连接地址池
请求参数 名称 类型 必填 描述 示例值 IoTCloudConnectorId string 是 云连接器实例 ID。iotcc-bp1odcab8tmno0hdq*ConnectionPoolIds array 否 连接地址池的 ID 列表。最多支持传入 20 个连接地址池 ID。string 否 连接地址池的 ID 列表。...
跨账号VPC间的私网访问服务
您可以通过私网连接建立VPC与阿里云服务之间安全稳定的私有连接，简化网络架构，避免通过公网访问服务带来的潜在安全风险。通过私网连接实现私网访问，您需要创建终端节点服务和终端节点。终端节点服务 终端节点服务可以与其他VPC的终端...
- 产品推荐
- 这些文档可能帮助您