脚本和输出语法
脚本的解析能力包括获取消息内容、转换数据格式、处理字符串、组装JSON格式数据和处理二进制数据等。输出文件是使用固定的JSON数组格式，将设备上报数据或脚本解析后的数据，映射到数字孪生节点中。本文介绍如何编写脚本和输出文件。背景...
JSON索引（2.0版）
JSON格式要求 在写入数据时，分析型数据库MySQL版对JSON类型数据中的属性键 key 和属性值 value 有以下要求。属性键 key：必须使用双引号（""）将 key 引起来。key 中不能包含点号（.），例如 {"a.b":"value"} 是不合法的JSON格式。属性值 ...
资源函数
例如 update_time_key="update_time"，其中 update_time 为MySQL数据库中数据更新的时间字段，该时间字段支持如下数据类型：Datetime、Timestamp、Int、Float、Decimal。需保证该时间字段的值随时间递增。说明 数据加工基于该时间字段做...
DROP TABLE
语法 DROP[TEMPORARY]TABLE[IF EXISTS]tbl_name[,tbl_name].[RESTRICT|CASCADE]说明 删除 PolarDB-X 1.0 数据表与删除原生MySQL数据库表的语法没有区别，系统会自动处理相关物理表的删除操作。更多详情，请参见 DROP TABLE Statement。注意...
创建索引或约束
本文为您介绍迁移 MySQL 数据库的数据至 OceanBase 数据库 MySQL 租户时，CREATE TABLE DDL 创建索引或约束支持的转换范围。索引或约束定义 create_definition:{ col_name column_definition|{INDEX|KEY}[index_name][index_type](key_part...
迁移MySQL或Doris数据到StarRocks
MySQL数据库的名称。是 column 待配置的表中需要同步的列名集合，使用JSON的数组描述字段信息。支持列裁剪，即列可以挑选部分列进行导出。重要 如果希望导入所有字列配置，则可以使用[’’]。是 splitPk 如果指定该参数，则...
访问Tablestore数据源
boolean"}|}|}""".stripMargin val options=new mutable.HashMap[String,String]()options.put("endpoint",endpoint)options.put("access.key.id",accessKeyId.get)options.put("access.key.secret",accessKeySecret.get)options.put(...
域名配置功能函数
可以配置的值为：on：开启 off（默认）：关闭 off 配置示例：{"Functions":[{"functionArgs":[{"argName":"enable","argValue":"on"},{"argName":"max_tries","argValue":2 },{"argName":"retain_args","argValue":"off"},{"argName":...
ApsaraDB For OceanBase数据源
insert into.ON DUPLICATE KEY UPDATE.：当主键或唯一性索引未冲突时，与 insert into 的行为一致。当主键或唯一性索引冲突时，新行会替换指定的字段。MySQL租户模式下支持 insert into.和 insert into.ON DUPLICATE KEY UPDATE.目的表...
TableStore数据源
本文介绍如何使用TableStore数据源进行数据分析或者交互式开发。建表语法 CREATE TABLE tbName USING tablestore OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);Table Schema 创建TableStore表时，无需显式定义表的...
通过外表导入至数仓版
本文介绍如何通过外表将云数据库RDS MySQL中的数据导入至 AnalyticDB MySQL。前提条件 RDS MySQL实例需与 AnalyticDB MySQL 集群位于同一个VPC，即所在专有网络的VPC ID相同。说明 登录 RDS控制台，单击实例ID，在 数据库连接 页面的 网络...
CreateMySqlDataSource-创建 MySQL 数据源
本接口用于创建 MySQL 数据源。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 ...
字典函数
本文介绍字典函数的语法规则，包括参数解释、函数示例等。函数列表 函数 说明 dct_make 构建字典。dct_update 更新字典。dct_delete 删除字典值。dct_keys 获取字典关键字列表。dct_values 获取字典值列表。dct_get 获取字典中某关键字的值...
常见问题概览
在对MySQL数据库进行创建索引等操作时报错 通过数据变更或SQLConsole执行DML语句时提示“Data truncation:Data too long”数据库返回“Incorrect string value”报错 数据管理DMS中出现“Data truncated for column”的原因与解决方案 在...
附录：DataHub消息格式
取值如下：INSERT：数据插入 UPDATE_BEFOR：数据更新前 UPDATE_AFTER：数据更新后 DELETE：数据删除 TRANSACTION_BEGIN：数据库事务开始 TRANSACTION_END：数据库事务结束 CREATE：数据库建表 ALTER：数据库表变更 QUERY：数据库变更的原始...
MariaDB数据源
是 无 writeMode 选择导入模式，支持insert into、on duplicate key update和replace into 三种方式：insert into：当主键/唯一性索引冲突时会写不进去冲突的行，以脏数据的形式体现。如果您通过脚本模式配置任务，请设置 writeMode 为...
配置PolarDB表到Tair表的映射关系
在完成 添加Tair缓存节点、创建Tair缓存节点账号 以及 创建Tair自定义连接地址 操作后，您需要配置表映射关系，明确PolarDB数据库中的表到Tair缓存节点的Redis协议的KV（Key-Value）结构或者KKV（Key-Key-Value）结构，从而使Tair缓存节点...
Canal
在很多情况下，利用Canal这个特性非常的有用，例如：将增量数据从数据库同步到其他系统 日志审计 数据库的实时物化视图 数据库表的temporal join变更历史 Flink还支持将Flink SQL中的INSERT、UPDATE或DELETE消息编码为Canal格式的JSON消息...
PHP访问（2.0版）
分析型数据库MySQL版端口号，可从分析型数据库MySQL版控制台获取端口号/连接云原生数据仓库AnalyticDB MySQL版2.0集群$ads_conn=mysqli_connect($ads_server_name,$ads_username,$ads_password,$ads_database,$ads_port);strsql="SELECT ...
DescribeRDSPerformance
DbInstType String 否 mysql 数据库引擎类型。返回数据 名称 类型 示例值 描述 Data Array of PartialPerformanceData 查询结果集。Key String cpuusage 监控指标名称。NodeName String pi-*节点名称。说明 仅数据库存储类型为PolarDB ...
约束和索引操作
本文为您介绍迁移 MySQL 数据库的数据至 OceanBase 数据库 MySQL 租户时，ALTER TABLE DDL 有关约束/索引操作同步支持的范围。总览 alter_option:{ ADD {INDEX|KEY}[index_name][index_type](key_part,.)[index_option].|ADD {FULLTEXT|...
Fn:SelectMapList
Fn:SelectMapList:key2-key1:value1-1 key3:value1-3-key1:value2-1 key2:value2-2-key1:value3-1 key2:value3-2-.缩写形式。SelectMapList-key2-key1:value1-1 key3:value1-3-key1:value2-1 key2:value2-2-key1:value3-1 key2:value3-2-....
ALIYUN:DTS:SynchronizationJob
当目标实例为阿里云分析型数据库MySQL版时，指定分析型数据库MySQL版的集群ID。当目标实例为DataHub时，指定DataHub实例中的Project名称。IP String 否 否 目标实例IP地址。当目标实例为通过专线接入的本地数据库时，必须指定此参数。...
DBeaver
本文测试了DBeaver 6.1.2 Community Edition版本与 AnalyticDB MySQL 在连通性、列举数据库、创建表等方面的兼容性，并给出测试结果图。测试环境 Java MySQL AnalyticDB MySQL DBeaver java version"1.8.0_161"Java(TM)SE Runtime ...
JMES语法
本文主要介绍JMES的常用语法和示例。JMES是一个增强型的JSON查询计算语言，不仅可以对JSON数据进行提取，还可以做计算与转换。关于JMES语法的详细介绍请参见 JMES Tutorial。数据加工中的 json_select、e_json、e_split 函数支持通过JMES...
设备标签
执行结果将异步返回，可以通过设置回调函数 on_thing_device_info_update 获得相关结果，示例如下：linkkit.on_thing_device_info_update=on_thing_device_info_update.def on_thing_device_info_update(self,request_id,code,data,message...
MySQL整库同步Kafka
本文为您介绍如何将MySQL整库同步Kafka，从而降低多个任务对MySQL数据库造成的压力。背景信息 MySQL CDC数据表主要用于获取MySQL数据，并可以实时同步数据表中的修改，经常用在复杂的计算场景。例如，作为一张维表和其他数据表做Join操作。...
UPDATE
您可以使用UPDATE语法修改表中符合条件的行。语法 单逻辑表 UPDATE[LOW_PRIORITY][IGNORE][schema_name.]tbl_name SET assignment_list[WHERE where_condition]value:{expr|DEFAULT} assignment:col_name=value assignment_list:assignment...
Cpc
您可以利用TairCpc将实时数据，按不同的去重维度，结构化地存储到Tair数据库中，即可在高速的访问场景中直接获得结果，实现存储、计算一体化。同时TairCpc提供多重聚合运算，可以在纳秒级聚合数据结果，具备实时风控的能力。TairCpc简介 ...
导出至自建MySQL
TABLE_PROPERTIES AnalyticDB MySQL 访问自建MySQL数据库的访问方式。url ECS实例的 主私网IP（即VPC地址）和目标库名（本文示例中为 test_adb）。查看步骤如下：登录 ECS管理控制台 并找到目标实例。在 实例详情 页签的 网络信息 区域，...
create_external_store
调用CLI命令关联外部数据源。当前支持关联RDS MySQL、OSS、本地CSV文件作为外部数据源。注意事项 说明 在进行日志数据查询分析时，...使用日志服务关联RDS MySQL进行数据关联查询的最佳实践，请参见 关联Logstore与MySQL数据库进行查询分析。
Schema探索
示例二：运行不带有ON子句的SHOW SERIES查询 使用 USE指定数据库>USE NOAA_water_database Using database NOAA_water_database>SHOW SERIES key-average_temperature,location=coyote_creek average_temperature,location=santa_monica h2...
导出至RDS MySQL
本文介绍如何通过 AnalyticDB MySQL 数仓版（3.0）的外表导出数据至云数据库RDS MySQL。前提条件 RDS MySQL实例需与 AnalyticDB MySQL 集群位于同一个VPC，即所在专有网络的VPC ID相同。说明 登录 RDS控制台，单击实例ID，在 数据库连接 ...
Java访问（2.0版）
不带重试的JDBC连接示例 您可以在业务系统的Java代码中添加以下代码，通过MySQL JDBC连接AnalyticDB for MySQL数据库。Connection connection=null;Statement statement=null;ResultSet rs=null;try { Class.forName(...
云数据库MySQL
具体操作，请参见 RDS MySQL数据库。已将0.0.0.0/0添加到RDS MySQL实例的白名单。具体操作，请参见 设置IP白名单。说明 0.0.0.0/0表示允许任何设备访问RDS实例，请谨慎使用。已完成项目和业务服务的创建。具体操作，请参见 项目 和 创建...
Python访问（2.0版）
import MySQLdb#打开数据库连接#host为分析型数据库MySQL版实例的访问URL的域名或IP#port为分析型数据库MySQL版实例的访问URL的端口#user为分析型数据库MySQL版...（通常为阿里云AK的access key）#db为分析型数据库MySQL版实例的database名称...
ALIYUN:DTS:MigrationJob
ALIYUN:DTS:MigrationJob类型用于购买一个数据库迁移实例，同时可以配置数据迁移任务。说明 建议使用新版资源 ALIYUN:DTS:Instance（用于购买DTS实例）和 ALIYUN:DTS:MigrationJob2（配置数据迁移任务）。语法 {"Type":"ALIYUN:DTS:...
ListProjects-分页查询项目列表
utf8mb4 NlsLengthSemantics string nlsLengthSemantics 属性，仅针对 Oracle 和 OceanBase 数据库 Oracle 租户数据源。null OperatingSystem string 操作系统（OceanBase 数据库无该参数）。Linux Region string 地域。...
ALIYUN:CloudPhone:KeyPair
语法 {"Type":"ALIYUN:CloudPhone:KeyPair","Properties":{"KeyPairName":String,"PublicKeyBody":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 KeyPairName String 是 否 密钥对名称。必须保持名称唯一性。长度为2~128个英文或...
update_index
请求语法 aliyunlog log update_index-project_name=<value>-logstore_name=<value>-index_detail=[-access-id=][-access-key=][-sts-token=][-region-endpoint=][-client-name=][-jmes-filter=][-format-output=][-decode-output=]请求...
- 产品推荐
- 这些文档可能帮助您