逻辑解码（wal2json）
wal2json插件会在每个事务中生成一个JSON对象。JSON对象中提供了所有新/旧元组，额外选项还可以包括事务时间戳、限定架构、数据类型、事务ID等属性。详情请参见 通过SQL获取JSON对象。通过SQL获取JSON对象 通过DMS登录RDS数据库。执行如下...
逻辑解码（wal2json）
wal2json插件会在每个事务中生成一个JSON对象。JSON对象中提供了所有新/旧元组，额外选项还可以包括事务时间戳、限定架构、数据类型、事务ID等属性。详情请参见 通过SQL获取JSON对象。注意事项 由于采用的replication方式为 REPLICA_...
逻辑解码（wal2json）
wal2json插件会在每个事务中生成一个JSON对象。JSON对象中提供了所有新/旧元组，额外选项还可以包括事务时间戳、限定架构、数据类型、事务ID等属性。详情请参见 通过SQL获取JSON对象。注意事项 由于 PolarDB PostgreSQL版（兼容Oracle）...
逻辑解码（wal2json）
wal2json插件会在每个事务中生成一个JSON对象。JSON对象中提供了所有新/旧元组，额外选项还可以包括事务时间戳、限定架构、数据类型、事务ID等属性。详情请参见 通过SQL获取JSON对象。注意事项 由于 PolarDB PostgreSQL版 采用的...
半结构化分析
支持的JSON数据类型有两种：JSON和JSONB。这两种类型在使用上几乎完全一致。其中，JSON数据类型直接存储输入文本，会保存JSON数据中语义无关的空格，并且会保持JSON对象键的顺序，以及JSON数据中重复的键和键对应的数据。对于重复键在查询...
快速开始
从 HBase增强版Shell访问 页面下载最新版本的HBase Shell，并根据 Shell使用指导 完成...通过Search查询的结果中，每行数据都会有一个列 id，这个 id 即为这一行数据在HBase表中的rowkey。拿到这个rowkey后，回查HBase，就可以获得完整数据。
JSON类型
在同一个应用里非常有可能有两种方法共存并且互补。不过，即便是在要求最大灵活性的应用中，我们还是推荐 JSON 文档有固定的结构。该结构通常是非强制的（尽管可能会强制一些业务规则），但是有一个可预测的结构会使书写概括一个表中的...
JSON支持
例如，要插入到一个有两列名为 myKey 和 value 的表中，可以执行以下操作：INSERT INTO persioninfo JSON '{"c1":"key","c2":"value"}' 默认情况下或者显式使用default NULL，JSON映射中省略的列将被设置为NULL，这意味着该列的任何预先...
JSON和JSONB类型
select json_object_keys('{"f1":"abc","f2":{"f3":"a","f4":"b"}}')json_object_keys-f1 f2 jsonb_object_keys(jsonb)json_populate_record(base anyelement,from_json json)anyelement 扩展from_json中的对象成一个行，它的列匹配由base...
GET_JSON_OBJECT
如果遇到英文双引号（"），需要用两个反斜杠（\\）进行转义。如果遇到英文单引号（'），需要用一个反斜杠（\）进行转义。path：必填。STRING类型。表示在 json 中的 path，以$开头。更多 path 信息，请参见 LanguageManual UDF。相关最佳...
在线访客名片文档
在线服务接入访客名片的工作有两个，分别为:访客端聊天窗数据埋点。客服端工作台访客信息展示。访客名片详细工程（Java语言）JavaDemo（PhP语言）phpdemo（C#语言）C#Demo 上述demo可以直接本地执行Application.java中的main函数。其他开发...
Dataphin数据集成模块自定义组件中关于自定义数据源...
为什么有两个地方要输入地址？问题原因 对于自定义组件和自定义数据源功能、概念不清楚。解决方案 自定义组件JSON串中Text部分相当于自定义数据源的属性名称，比如：链接地址、用户名、密码等配置属性名；Placeholder相当于具体的值，具体...
查询文件
SkipPartialDataRecord 该参数为True时，如果CSV中某一列值不存在或者JSON中某一个Key不存在，则直接跳过整个记录。该参数为False时，则把该列当做null来处理。假如某一行的列为firstname,lastname,age。SQL为 select_1,_4 from ossobject...
查询和分析JSON日志的常见问题
当日志中有JSON数组时，您可以结合cast函数和UNNEST子句，展开JSON数组，再进行聚合统计。示例1 例如您要统计所有请求成功的订单的金额，可参见如下思路。使用查询语句过滤出请求成功的日志，然后在分析语句中使用json_extract函数提取出 ...
如何对JSON类型进行高效分析
PolarDB 列存可以高效分析JSON数据，接近行存两个数量级。由于数据集与查询模式均不同，线上业务的性能收益可能存在一定差异，需要以实际情况为准。虚拟列 虚拟列（Virtual Columns）作为一种特殊类型的列，其值不是通过插入或更新的方式...
多元索引嵌套类型
假设嵌套类型的列名为 tags，其元素只有一行包括两个JSON元素，具体值为[{"tagName":"tag1","score":0.8},{"tagName":"tag2","score":0.2}]，使用不同方式查询嵌套类型的列数据时的区别如下：嵌套类型的子列支持直接与运算符组合使用 SQL...
SelectObject
未编码前的值最多为两个字符，以字符的ANSI值表示，例如在Java中使用 表示换行。子节点：None 父节点：CSV（输入、输出），JSON（输出）FieldDelimiter 字符串 指定CSV列分隔符，以Base64编码。默认值为,（可选）。未编码前的值必须为一个...
RestAPI（HTTP形式）数据源
multiData：从返回的JSON中取一个JSON数组，传递多条数据给writer。是 无 responseType 返回结果的数据格式，目前仅支持JSON格式。是 JSON column 读取字段列表，type指定源数据的类型，name指定当前column数据获取的JSON路径。您可以指定...
管理Kafka JSON Catalog
否 可配置的值有以下两种：SQL（默认值）ISO-8601 infer-schema.flatten-nested-columns.enable Boolean 解析JSON格式消息体（Value）时，是否递归式地展开JSON中的嵌套列。否 参数取值如下：true：递归式展开。对于被展开的列，Flink使用...
JSON索引（2.0版）
在JSON串 {key:value,key:value} 中，每个 key:value 为一个属性对，其中 key 为属性键，value 为属性值。示例 以下SQL示例包含多种JSON数据格式，供您参考使用。insert into json_tbl(id,sid,json_test)values(0,0,'{"id":0,"name":"abc",...
JSON函数和操作符
'{"a":1,"b":2}':jsonb@>'{"b":2}':jsonb→t jsonb→boolean 第二个JSON中是否包含第一个JSON值?'{"b":2}':jsonb,"b":2}':jsonb→t jsonb?text→boolean 文本字符串是否作为JSON值中的顶级键或数组元素存在?'{"a":1,"b":2}':jsonb?'b'→t '...
文本搜索函数和操作符
'a:1 b:2':tsvector|'c:1 d:2 b:3':tsvector→'a':1 'b':2,5 'c':3 'd':4 tsquery&tsquery→tsquery ANDs两个 tsquery 一起，生成一个匹配两个输入查询的匹配文档的查询。'fat|rat':tsquery&'cat':tsquery→('fat'|'rat')&'cat' tsquery|...
自定义函数（邀测中）
假设这里的函数有两个入参a和b，则AnalyticDB for MySQL发来的数据每行都会有两个数，第一个数是a，第二个数是b。if(row.size()=2){ result.add(testFunc(row.getInteger(0),row.getInteger(1)));} else { throw new RuntimeException("row...
复杂类型函数
JSON_TUPLE 在一个标准的JSON字符串中，按照输入的一组键抽取各个键指定的字符串。TO_JSON 将指定的复杂类型输出为JSON字符串。JSON_OBJECT 生成JSON OBJECT，要求key和value成对出现。JSON_ARRAY 生成JSON ARRAY。将一个可能为空的JSON...
支持的函数
(timepoint1,temporal1)OVERLAPS(timepoint2,temporal2)如果由(timepoint1,temporal1)和(timepoint2,temporal2)定义的两个时间间隔重叠，则返回true。DATE_FORMAT 使用DATE_FORMAT函数将字符串类型的日期从原格式转换至目标格式。DATE_...
字符串函数
CHAR_MATCHCOUNT 命令格式 bigint char_matchcount(string,string)命令说明 计算 str1 中有多少个字符出现在 str2 中。参数说明 str1、str2：必填。STRING类型，必须为有效的UTF-8字符串。如果对比过程中发现有无效字符（非UNICODE编码），...
查询文件
JSON文件查询 查询JSON文件时，在SQL的From语句中尽可能缩小From后的JSON Path范围。如下是JSON文件示例：{"contacts":[{"firstName":"John","lastName":"Smith","address":{"streetAddress":"21 2nd Street","city":"New York","state":...
子文档（sub_doc）配置
查询行为解读 表达式概念，virtual attribute 表达式中只包含主 doc 上的 attribute 或者 variable 的为主表达式，如果表达式中有 sub doc attribute 或者 sub doc variable 参与了运算，那么这个表达式为子表达式，对应返回的结果（如 ...
创建索引
其中_topic_和_source_的索引分词符为空，查询这两个字段时，关键字必须完全匹配。tag_为前缀的字段不支持全文索引。您需要创建字段索引后，才能执行查询和分析操作，例如*|select"_tag_:_receive_time_。日志中存在同名字段（例如都为...
使用Druid
非安全独立Hadoop集群，请按照如下操作进行：确保集群间能够通信（两个集群在一个安全组下，或两个集群在不同安全组，但两个安全组之间配置了访问规则）。在E-MapReduce Druid集群的每个节点的指定路径下，放置一份Hadoop集群中/etc/ecm/...
HTTP API
["2017-03-01T00:17:18Z",12.4,"12","14"]]}]}]} measurement mymeas 中有两个数据点。在第一个数据点中，时间戳是2017-03-01T00:16:18Z，field key myfield 的值是33.1，tag key mytag1 和 mytag2 没有tag value。在第二个数据点中，时间...
MergeShard
调用MergeShard接口合并两个相邻的readwrite状态的Shard。在参数中指定一个shardID，服务端自动查询相邻的下一个Shard进行合并。接口说明 Host由Project名称和日志服务Endpoint构成，您需要在Host中指定Project。每个Shard均有范围，为MD5...
新功能发布记录
无 外表文件名 修复外表文件名中有冒号时报错的问题。无 2023年9月 湖仓版 类别 名称 说明 相关文档 新增 Spark应用性能诊断 湖仓版（3.0）推出Spark应用性能诊断功能，帮助您快速定位和分析性能瓶颈问题，提高问题解决效率。Spark应用性能...
函数概览
zip_with函数 根据Lambda表达式中的定义将两个数组合并为一个数组。Map映射函数和运算符 函数名称 说明 支持SQL 支持SPL 下标运算符 获取Map中目标键的值。cardinality函数 计算Map的大小。element_at函数 获取Map中目标键的值。histogram...
Callback
您需要设置两个自定义的参数，分别为 x:var1 和 x:var2，对应的值分别为value1和value2，则构造的JSON格式如下：{"x:var1":"value1","x:var2":"value2"} 步骤2：构造回调请求 将Callback和callback-var参数附加到OSS请求时，需要对上述构造...
通过数据同步功能同步Kafka至湖仓版（推荐）
例如，两个数据同步任务的OSS路径分别为oss:/adb_demo/test/sls1/和oss:/adb_demo/test/，OSS路径有相互前缀关系，数据同步过程中会有数据覆盖。目标库表配置 参数说明如下：参数名称 参数说明 库名 同步到 AnalyticDB MySQL 的数据库名称...
使用示例
目前云呼叫中心与阿里云...函数模块执行成功后，流程进入 分支模块，在分支模块中，我们根据函数模块的出参来设置我们的判断条件，这里作为示例，我们只提供了两个条件作为参考。根据 分支模块 的执行结果，最终通话分配到了指定的技能组。
通用参考
输入数据中存在冲突 在原始日志中包含大小写不敏感重复的字段时，如某一条日志同时存在 Status、status 两个字段，SPL会随机选取其中一个字段作为输入，舍弃另一列；举例如下：SPL语句*|extend status_cast=cast(status as bigint)输入数据...
内建函数概述
DATEDIFF 计算两个日期的差值并按照指定的单位表示。DATEPART 提取日期中符合指定时间单位的字段值。DATETRUNC 提取日期按照指定时间单位截取后的值。FROM_UNIXTIME 将数字型的UNIX值转换为日期值。GETDATE 获取当前系统时间。ISDATE 判断...
接口出参
若上一步定义的解析表达式在Response中有多个匹配时，指定第几个字符串作为出参。从0开始，-n表示倒数第n个，取值区间为[-99,99]。如果想要取随机匹配项，请填写 random。Body:JSON类型 JSON格式解析 支持两种类型的返回信息：application/...
- 产品推荐
- 这些文档可能帮助您