本页介绍天翼云TeleDB数据库Oracle语法中的字符函数。 regexpcount REGEXPCOUNT返回pattern在sourcechar串中出现的次数。 plaintext teledb select REGEXPCOUNT('teledbpgteledbpg','pg') from DUAL; regexpcount 2 (1 row) instr instr函数返回要截取的字符串在源字符串中的位置。 plaintext teledb select instr('helloworld','l') from dual; instr 3 (1 row) regexpsubstr string：需要进行正则处理的字符串。 pattern：进行匹配的正则表达式。 position：起始位置，从字符串的第几个字符开始正则表达式匹配（默认为1） 注意 字符串最初的位置是1而不是0。 occurrence：获取第几个分割出来的组（分割后最初的字符串会按分割的顺序排列成组）。 modifier：模式（‘i’不区分大小写进行检索；‘c’区分大小写进行检索。默认为‘c’）针对的是正则表达式里字符大小写的匹配。 plaintext teledb SELECT REGEXPSUBSTR('17,20,23','[^,]+',1,1,'i') AS STR FROM DUAL; str 17 (1 row) teledb regexpreplace regexpreplace(1,2,3,4,5,6) 语法说明： 1：字段 2：替换的字段 3：替换成什么 4：起始位置（默认从1开始） 5：替换的次数（0是无限次） 6：不区分大小写 plaintext teledb select regexpreplace('teledbteledb','x','ee',1,1) from dual; regexpreplace teledbeeteledb (1 row) teledb nlssort 指定排序规则。 plaintext teledb

密钥包装算法 说明 设置 RSAESOAEPSHA256 具有“SHA256”哈希函数的OAEP的RSA加密算法。 请您根据自己的HSM功能选择加密算法。 如果您的HSM支持“RSAESOAEPSHA256”加密算法，推荐使用“RSAESOAEPSHA256”加密密钥材料。 如果您的HSM不支持“OAEP”选项，用户可以使用“RSAESPKCS1V15”加密密钥材料。 “RSAESOAEPSHA1”加密算法已经不再安全，请谨慎选择。 RSAESOAEPSHA1 具有“SHA1”哈希函数的OAEP的RSA加密算法。 请您根据自己的HSM功能选择加密算法。 如果您的HSM支持“RSAESOAEPSHA256”加密算法，推荐使用“RSAESOAEPSHA256”加密密钥材料。 如果您的HSM不支持“OAEP”选项，用户可以使用“RSAESPKCS1V15”加密密钥材料。 “RSAESOAEPSHA1”加密算法已经不再安全，请谨慎选择。 SM2ENCRYPT 国密推荐的SM2椭圆曲线公钥密码算法。 请在支持国密的局点使用SM2加密算法。

本页介绍天翼云TeleDB数据库PL/pgsql函数的参数引用方法。 PL/pgsql函数的参数是以$1,$2这样标识符来进行传递，也支持命名参数，所以参数的定义可以用下面的方式。 无命名参数 plaintext teledb CREATE OR REPLACE FUNCTION f2(text) RETURNS TEXT AS teledb $$ teledb$ BEGIN teledb$ RETURN $1; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL; CREATE FUNCTION teledb SELECT FROM f2('teledb'); f2 teledb (1 row) 给标识符指定别名 plaintext teledb CREATE OR REPLACE FUNCTION f2(text) RETURNS TEXT AS teledb $$ teledb$ DECLARE teledb$ axm ALIAS FOR $1; axm是$1的别名 teledb$ BEGIN teledb$ RETURN axm; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL teledb ; CREATE FUNCTION teledb SELECT FROM f2('teledb'); f2 teledb (1 row) 命名参数 plaintext teledb CREATE OR REPLACE FUNCTION f2(axm text) RETURNS TEXT AS teledb $$ teledb$ DECLARE teledb$ vxm ALIAS FOR $1; teledb$ BEGIN teledb$ RAISE NOTICE 'axm % ; vxm % ; $1 %',axm,vxm,$1; teledb$ RETURN $1; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL; CREATE FUNCTION teledb SELECT FROM f2('teledb'); NOTICE: axm teledb ; vxm teledb ; $1 teledb f2 teledb (1 row)

本页介绍天翼云TeleDB数据库PL/pgsql函数的参数引用方法。 PL/pgsql函数的参数是以$1,$2这样标识符来进行传递，也支持命名参数，所以参数的定义可以用下面的方式。 无命名参数 plaintext teledb CREATE OR REPLACE FUNCTION f2(text) RETURNS TEXT AS teledb $$ teledb$ BEGIN teledb$ RETURN $1; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL; CREATE FUNCTION teledb SELECT FROM f2('teledb'); f2 teledb (1 row) 给标识符指定别名 plaintext teledb CREATE OR REPLACE FUNCTION f2(text) RETURNS TEXT AS teledb $$ teledb$ DECLARE teledb$ axm ALIAS FOR $1; axm是$1的别名 teledb$ BEGIN teledb$ RETURN axm; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL teledb ; CREATE FUNCTION teledb SELECT FROM f2('teledb'); f2 teledb (1 row) 命名参数 plaintext teledb CREATE OR REPLACE FUNCTION f2(axm text) RETURNS TEXT AS teledb $$ teledb$ DECLARE teledb$ vxm ALIAS FOR $1; teledb$ BEGIN teledb$ RAISE NOTICE 'axm % ; vxm % ; $1 %',axm,vxm,$1; teledb$ RETURN $1; teledb$ END; teledb$ $$ teledb LANGUAGE PLPGSQL; CREATE FUNCTION teledb SELECT FROM f2('teledb'); NOTICE: axm teledb ; vxm teledb ; $1 teledb f2 teledb (1 row)

1. 连接至数据库并建表 建表语句如下： CREATE TABLE ukpricepaid ( price UInt32, date Date, postcode1 LowCardinality(String), postcode2 LowCardinality(String), type Enum8('terraced' 1, 'semidetached' 2, 'detached' 3, 'flat' 4, 'other' 0), isnew UInt8, duration Enum8('freehold' 1, 'leasehold' 2, 'unknown' 0), addr1 String, addr2 String, street LowCardinality(String), locality LowCardinality(String), town LowCardinality(String), district LowCardinality(String), county LowCardinality(String) ) ENGINE MergeTree ORDER BY (postcode1, postcode2, addr1, addr2); 2. 预处理并插入数据 我们将使用url函数将数据流式传输到云数据库ClickHouse中。我们首先需要对一些传入的数据进行预处理，包括： 下面将邮政编码拆分为两个不同的列 postcode1和postcode2，这样更适合存储和查询。 将时间字段转换为日期，因为它只包含00:00时间。 忽略UUid字段，因为在分析中不需要它。 使用transform函数将type和duration转换为更易读的枚举字段。 将isnew字段从单字符字符串（Y/N）转换为UInt8字段，取值为0或1。 删除最后两列，因为它们的值都相同（为0）。 url函数将数据从Web服务器流式传输到您的云数据库ClickHouse表中。以下命令将向ukpricepaid表中插入500万行数据： INSERT INTO ukpricepaid WITH splitByChar(' ', postcode) AS p SELECT toUInt32(pricestring) AS price, parseDateTimeBestEffortUS(time) AS date, p[1] AS postcode1, p[2] AS postcode2, transform(a, ['T', 'S', 'D', 'F', 'O'], ['terraced', 'semidetached', 'detached', 'flat', 'other']) AS type, b 'Y' AS isnew, transform(c, ['F', 'L', 'U'], ['freehold', 'leasehold', 'unknown']) AS duration, addr1, addr2, street, locality, town, district, county FROM url( ' 'CSV', 'uuidstring String, pricestring String, time String, postcode String, a String, b String, c String, addr1 String, addr2 String, street String, locality String, town String, district String, county String, d String, e String' ) SETTINGS maxhttpgetredirects10; 输入命令并执行后请等待数据插入，等待时间取决于网络速度。

重置索引优化建议 索引优化建议模块提供indexadvisoryreset() 函数来重置模块，清除所有节点中索引优化建议相关的数据信息 plaintext teledb select indexadvisoryreset()；

本章节主要介绍翼MapReduce如何添加作业。 用户可将自己开发的程序提交到翼MR中，执行程序并获取结果。 本章节以MapReduce作业为例指导您在翼MR集群页面如何提交一个新的作业。MapReduce作业用于提交jar程序快速并行处理大量数据，是一种分布式数据处理模式和执行环境。 若在集群详情页面不支持“作业管理”和“文件管理”功能，请通过后台功能来提交作业。 用户创建作业前需要将本地数据上传至OBS系统用于计算分析。当然翼MR也支持将OBS中的数据导入至HDFS中，并使用HDFS中的数据进行计算分析。数据完成处理和分析后，您可以将数据存储在HDFS中，也可以将集群中的数据导出至OBS系统。需要注意，HDFS和OBS也支持存储压缩格式的数据，目前支持存储bz2、gz压缩格式的数据。 通过界面提交作业 1.登录翼MR管理控制台。 2.选择“集群列表 > 现有集群”，选中一个运行中的集群并单击集群名称，进入集群信息页面。 3.若集群开启Kerberos认证时执行该步骤，若集群未开启Kerberos认证，请无需执行该步骤。 在“概览”页签的基本信息区域，单击“IAM用户同步”右侧的“单击同步”进行IAM用户同步。 说明 当IAM用户的用户组的所属策略从翼MR ReadOnlyAccess向翼MR CommonOperations、翼MR FullAccess、翼MR Administrator变化时，由于集群节点的SSSD（System Security Services Daemon）缓存刷新需要时间，因此同步完成后，请等待5分钟，等待新修改策略生效之后，再进行提交作业。否则，会出现提交作业失败的情况 。 当IAM用户的用户组的所属策略从翼MR CommonOperations、翼MR FullAccess、翼MR Administrator向翼MR ReadOnlyAccess变化时，由于集群节点的SSSD缓存刷新需要时间，因此同步完成后，请等待5分钟，新修改策略才能生效 。 4.单击“作业管理”，进入“作业管理”页签。 5.单击“添加”，进入“添加作业”页面。 6.“作业类型”选择“MapReduce”，并配置其他作业信息。 作业配置信息 参数 参数说明 作业名称 作业名称，只能由字母、数字、中划线和下划线组成，并且长度为1～64个字符。 说明 建议不同的作业设置不同的名称。 执行程序路径 待执行程序包地址，需要满足如下要求： 最多为1023字符，不能包含; 执行程序参数 可选参数，程序执行的关键参数。多个参数间使用空格隔开。 配置方法：程序类名数据输入路径数据 输出路径 程序类名：由用户程序内的函数指定，翼MR只负责参数的传入。 数据输入路径：通过单击“HDFS”或者“OBS”选择或者直接手动输入正确路径。 数据输出路径：输出路径请手动输入一个不存在的目录。 最多为2047字符，不能包含; 服务配置参数 可选参数，用于为本次执行的作业修改服务配置参数。 该参数的修改仅适用于本次执行的作业，如需对集群永久生效，请参考配置服务参数页面进行修改。 如需添加多个参数，请单击右侧增加，如需删除参数，请单击右侧“删除”。 常用服务配置参数请见下表。 命令参考 用于展示提交作业时提交到后台执行的命令。 服务配置参数 参数 参数说明 取值样例 fs.obs.access.key 访问OBS的密钥ID。 fs.obs.secret.key 访问OBS与密钥ID对应的密钥。 7.确认作业配置信息，单击“确定”，完成作业的新增。 作业新增完成后，可对作业进行管理。

2.请求失败返回值示例 plaintext { "statusCode": 400012, "message": "文件格式不合法", "details": "仅支持jpeg/png/jpg/bmp格式", "error":"AIOP400012" } 状态码 http状态码 描述 200 表示请求成功。 错误码说明 4 开头为业务错误码，5 开头为服务错误码。 错误码 错误信息 错误描述 CTAPI0009 无效json的body参数 AIOP4002 body传入不是字典 body传入不是字典 AIOP4008 base64数据处理异常 base64数据处理异常 AIOP4009 请求文件格式不合法，仅支持 jpeg/png/jpg/bmp 格式 请求文件格式不合法，仅支持 jpeg/png/jpg/bmp 格式 AIOP4010 单张图片大小超过10M 单张图片大小超过10M AIOP4011 图片尺寸不符合要求,分辨率长宽尺寸应不高于5000不低于32 图片尺寸不符合要求,分辨率长宽尺寸应不高于5000不低于32 AIOP5000 OCR服务接口异常，请联系管理员 OCR服务接口异常，请联系管理员 base64 编码规则：使用常规的 safe base64 编码方式 python 中推荐使用 base64.urlsafeb64encode() 函数进行编码 java 中推荐使用 BASE64.getUrlEncoder().encodeToString() 函数进行编码

本页介绍天翼云TeleDB数据库Oracle语法中的字符函数。 regexpcount REGEXPCOUNT返回pattern在sourcechar串中出现的次数。 plaintext teledb select REGEXPCOUNT('teledbpgteledbpg','pg') from DUAL; regexpcount 2 (1 row) instr instr函数返回要截取的字符串在源字符串中的位置。 plaintext teledb select instr('helloworld','l') from dual; instr 3 (1 row) regexpsubstr string：需要进行正则处理的字符串。 pattern：进行匹配的正则表达式。 position：起始位置，从字符串的第几个字符开始正则表达式匹配（默认为1） 。 注意 字符串最初的位置是1而不是0。 occurrence：获取第几个分割出来的组（分割后最初的字符串会按分割的顺序排列成组）。 modifier：模式（‘i’不区分大小写进行检索；‘c’区分大小写进行检索。默认为’c’）针对的是正则表达式里字符大小写的匹配。 plaintext teledb SELECT REGEXPSUBSTR('17,20,23','[^,]+',1,1,'i') AS STR FROM DUAL; str 17 (1 row) teledb regexpreplace regexpreplace(1,2,3,4,5,6) 语法说明：1：字段 2：替换的字段 3：替换成什么 4：起始位置（默认从1开始） 5：替换的次数（0是无限次） 6：不区分大小写 plaintext teledb select regexpreplace('teledbteledb','x','ee',1,1) from dual; regexpreplace teledbeeteledb (1 row) teledb nlssort 指定排序规则。 plaintext teledb

本页介绍天翼云TeleDB数据库Oracle语法中的字符函数。 regexpcount REGEXPCOUNT返回pattern在sourcechar串中出现的次数。 plaintext teledb select REGEXPCOUNT('teledbpgteledbpg','pg') from DUAL; regexpcount 2 (1 row) instr instr函数返回要截取的字符串在源字符串中的位置。 plaintext teledb select instr('helloworld','l') from dual; instr 3 (1 row) regexpsubstr string：需要进行正则处理的字符串。 pattern：进行匹配的正则表达式。 position：起始位置，从字符串的第几个字符开始正则表达式匹配（默认为1）。 注意 字符串最初的位置是1而不是0。 occurrence：获取第几个分割出来的组（分割后最初的字符串会按分割的顺序排列成组）。 modifier：模式（‘i’不区分大小写进行检索；‘c’区分大小写进行检索。默认为’c’）针对的是正则表达式里字符大小写的匹配。 plaintext teledb SELECT REGEXPSUBSTR('17,20,23','[^,]+',1,1,'i') AS STR FROM DUAL; str 17 (1 row) teledb regexpreplace regexpreplace(1,2,3,4,5,6) 语法说明：1：字段 2：替换的字段 3：替换成什么 4：起始位置（默认从1开始） 5：替换的次数（0是无限次） 6：不区分大小写 plaintext teledb select regexpreplace('teledbteledb','x','ee',1,1) from dual; regexpreplace teledbeeteledb (1 row) teledb nlssort 指定排序规则。 plaintext teledb

本页介绍天翼云TeleDB数据库Oracle语法中的字符函数。 regexpcount REGEXPCOUNT返回pattern在sourcechar串中出现的次数。 plaintext teledb select REGEXPCOUNT('teledbpgteledbpg','pg') from DUAL; regexpcount 2 (1 row) instr instr函数返回要截取的字符串在源字符串中的位置。 plaintext teledb select instr('helloworld','l') from dual; instr 3 (1 row) regexpsubstr string：需要进行正则处理的字符串。 pattern：进行匹配的正则表达式。 position：起始位置，从字符串的第几个字符开始正则表达式匹配（默认为1） 注意 字符串最初的位置是1而不是0。 occurrence：获取第几个分割出来的组（分割后最初的字符串会按分割的顺序排列成组）。 modifier：模式（‘i’不区分大小写进行检索；‘c’区分大小写进行检索。默认为‘c’）针对的是正则表达式里字符大小写的匹配。 plaintext teledb SELECT REGEXPSUBSTR('17,20,23','[^,]+',1,1,'i') AS STR FROM DUAL; str 17 (1 row) teledb regexpreplace regexpreplace(1,2,3,4,5,6) 语法说明： 1：字段 2：替换的字段 3：替换成什么 4：起始位置（默认从1开始） 5：替换的次数（0是无限次） 6：不区分大小写 plaintext teledb select regexpreplace('teledbteledb','x','ee',1,1) from dual; regexpreplace teledbeeteledb (1 row) teledb nlssort 指定排序规则。 plaintext teledb

本页介绍天翼云TeleDB数据库Oracle语法中的字符函数。 regexpcount REGEXPCOUNT返回pattern在sourcechar串中出现的次数。 plaintext teledb select REGEXPCOUNT('teledbpgteledbpg','pg') from DUAL; regexpcount 2 (1 row) instr instr函数返回要截取的字符串在源字符串中的位置。 plaintext teledb select instr('helloworld','l') from dual; instr 3 (1 row) regexpsubstr string：需要进行正则处理的字符串。 pattern：进行匹配的正则表达式。 position：起始位置，从字符串的第几个字符开始正则表达式匹配（默认为1） 注意 字符串最初的位置是1而不是0。 occurrence：获取第几个分割出来的组（分割后最初的字符串会按分割的顺序排列成组）。 modifier：模式（‘i’不区分大小写进行检索；‘c’区分大小写进行检索。默认为‘c’）针对的是正则表达式里字符大小写的匹配。 plaintext teledb SELECT REGEXPSUBSTR('17,20,23','[^,]+',1,1,'i') AS STR FROM DUAL; str 17 (1 row) teledb regexpreplace regexpreplace(1,2,3,4,5,6) 语法说明： 1：字段 2：替换的字段 3：替换成什么 4：起始位置（默认从1开始） 5：替换的次数（0是无限次） 6：不区分大小写 plaintext teledb select regexpreplace('teledbteledb','x','ee',1,1) from dual; regexpreplace teledbeeteledb (1 row) teledb nlssort 指定排序规则。 plaintext teledb

示例 Fetch URL javascript addEventListener("fetch", event > { return event.respondWith( fetch(" ) }) 带构建函数 javascript async function handleRequest() { const init { headers: { "contenttype": "application/json;charsetUTF8", }, redirect: "follow" } const response await fetch(url, init) return new Response(response, init) } addEventListener("fetch", event > { return event.respondWith(handleRequest()) }) 相关参考 示例代码：发起网络请求获取远程资源

示例 Fetch URL javascript addEventListener("fetch", event > { return event.respondWith( fetch(" ) }) 带构建函数 javascript async function handleRequest() { const init { headers: { "contenttype": "application/json;charsetUTF8", }, redirect: "follow" } const response await fetch(url, init) return new Response(response, init) } addEventListener("fetch", event > { return event.respondWith(handleRequest()) }) 相关参考 示例代码：发起网络请求获取远程资源

挂载 在NAS中，挂载是指将远程文件系统连接到本地计算机的过程，从而使得本地计算机可以像访问本地文件系统一样访问远程文件系统。这个过程也被称为网络文件系统（NFS）挂载或共享文件夹挂载。 挂载点 文件系统创建之后需挂载至服务器才能访问和使用，在挂载过程中，远程文件系统被映射到本地计算机的一个目录上，这个目录称为挂载点。一旦成功挂载，本地计算机就可以像访问本地文件一样访问远程文件系统中的文件和目录，可以进行读、写、删除等操作。同一个挂载点可以被多个计算节点同时挂载，共享访问。 VPC VPC是一种基于云的虚拟化网络环境，可以自定义网络拓扑、IP地址范围、子网和路由表等组件，并提供隔离、安全、可扩展的网络环境。它可以为云计算应用程序提供网络隔离、网络访问控制、流量管理等功能。 POSIX POSIX（Portable Operating System Interface，可移植操作系统接口）是由IEEE组织发布的一系列计算机操作系统的接口标准，旨在提高操作系统间的互操作性，实现不同操作系统之间的兼容性。POSIX标准规定了一系列系统调用、标准库函数和命令行工具等，这些规范旨在确保在遵循POSIX的系统上编写的应用程序可以在不同的POSIX系统之间移植和运行。POSIX标准还规定了一些与文件系统、进程、线程、信号、网络等相关的API和规范，使得开发人员可以编写可移植的应用程序。

本节主要介绍设置应用生命周期 部署应用组件时，在“基本配置”界面，“部署系统”选择“云容器引擎”的应用组件，ServiceStage提供了回调函数，在应用的生命周期的特定阶段执行调用，比如应用组件在停止前希望执行某项操作，就可以注册相应的钩子函数。 目前提供的生命周期回调函数如下所示。 启动命令：容器将会以该启动命令启动。 启动后处理：应用启动后触发。 停止前处理：应用停止前触发。 操作步骤 1、部署应用组件时，在“组件配置”界面，展开“高级设置 > 部署配置”。 2、单击“启动命令”，设置容器“运行命令”和“运行参数”。 Docker的镜像拥有存储镜像信息的相关元数据，如果不设置“生命周期”命令和参数，应用运行时将运行镜像制作时提供的默认的命令和参数，Docker将这两个字段定义为“Entrypoint”和 "CMD"。关于这两个参数的详细信息，请查看Docker的Entrypoint说明和CMD说明。 如果在部署应用组件时填写了应用的“运行命令”和“运行参数”，将会覆盖镜像构建时的默认命令 "Entrypoint"、"CMD"，规则如表1所示。 3、单击“生命周期”，设置“启动后处理”和“停止前处理”参数，参数说明如表2所示。 表 启动命令参数说明 镜像Entrypoint 镜像CMD 应用运行命令 应用运行参数 最终执行 ::::: [touch] [/root/test] 未设置 未设置 [touch /root/test] [touch] [/root/test] [mkdir] 未设置 [mkdir] [touch] [/root/test] 未设置 [/opt/test] [touch /opt/test] [touch] [/root/test] [mkdir] [/opt/test] [mkdir /opt/test] 表 生命周期参数说明 参数 说明 :: 命令行方式 在组件实例中执行指定的命令，配置为需要执行的命令。命令的格式为Command Args[1] Args[2]…（Command为系统命令或者用户自定义可执行程序，如果未指定路径则在默认路径下需找可执行程序），如果需要执行多条命令，建议采用将命令写入脚本执行的方式。 需要执行的命令示例如下： exec: command: /install.sh installagent 请在执行脚本中填写： /install.sh installagent。 这条命令表示组件部署成功后将执行installagent安装。 Http请求方式 发起一个HTTP调用请求。配置参数如下： 路径：请求的URL路径，可选项。 端口：请求的端口，必选项。 主机地址：请求的IP地址，可选项，默认是应用所在的节点IP。

本文介绍函数运行时的FetchEvent的定义与用法。 分配给运行时的HTTP请求的事件类型。详细定义请参见MDN官方文档FetchEvent。 上下文 javascript addEventListener("fetch", event > { event.respondWith(handleRequest(event)) }) 属性 event.request Request 触发FetchEvent的HTTP请求。 方法 当运行时脚本收到请求时，运行时将触发FetchEvent，然后触发事件类型为fetch事件侦听器进行处理。事件处理程序可以调用event对象的以下方法来进行控制： event.respondWith( response RequestPromise ) void 拦截请求并发送自定义响应。 必须调用respondWith()进行有效的响应，否则运行时会报错。 生命周期 当边缘接收到一个请求，该请求的URL映射到用户函数时，FetchEvent生命周期开始；这时运行时触发一个事件，并创建一个FetchEvent对象传递给运行时的第一个注册为fetch的事件处理程序。 事件处理程序可以使用respondWith()来拦截请求并允许用户发送自定义响应。 如果fetch事件处理程序未调用respondWith()，则运行时会将事件传递到下一个注册的fetch事件处理程序。 javascript addEventListener('fetch', (event) > { event.respondWith(handle(event)); }); async function handle(event) { // 1.异步发起一个fetch请求，但是我们不使用await，所以该请求会并行执行 fetch(" // 2.立刻发起回复。这个回复hello world发回给客户端时，前面发起的fetch可能没有执行完毕。 return "hello world"; } 相关参考 示例代码：返回HTML页面 示例代码：返回JSON内容

详细示例 通过云数据库ClickHouse的Kafka函数可以实现数据从Kafka到云数据库ClickHouse的迁移。下面是一个示例，展示了如何使用Kafka函数进行数据迁移： 1. 首先，创建Kafka消费表： sql CREATE TABLE queue ( timestamp UInt64, level String, message String ) ENGINE Kafka('localhost:9092', 'topic', 'group1', 'JSONEachRow'); 2. 然后，创建云数据库ClickHouse表以存储从Kafka迁移的数据： sql CREATE TABLE daily ( day Date, level String, total UInt64 ) ENGINE SummingMergeTree(day, (day, level), 8192); 3. 接下来，创建一个物化视图，将引擎中的数据转换并放入先前创建的表中： CREATE MATERIALIZED VIEW consumer TO daily AS SELECT toDate(toDateTime(timestamp)) AS day, level, count() as total FROM queue GROUP BY day, level; 当物化视图连接到引擎时，它会在后台开始收集数据。这样，您就可以持续从 Kafka 接收消息并使用 SELECT 将其转换为所需的格式。一个 Kafka 表可以有任意多个物化视图，它们不直接从 Kafka 表中读取数据，而是接收新的记录（以块的形式），这样您就可以将数据写入具有不同详细级别的多个表中（带有分组 聚合和不带分组）。 4. 最后，查询数据以确认迁移完成： SELECT level, sum(total) FROM daily GROUP BY level;

select from teledbpg order by md5(nickname); id nickname + 1 hello,pgxc 3 pg 1 teledb (3 rows) 排序也能用子查询。 plaintext teledb select from teledbpg order by (select id from teledbpg order by random() limit 1); id nickname + 1 teledb 1 hello,pgxc 3 pg (3 rows) null 值排序结果处理 plaintext teledb insert into teledbpg values(4,null); INSERT 0 1 null 值记录排在最前面。 plaintext teledb select from teledbpg order by nickname nulls first; id nickname + 4 1 hello,pgxc 3 pg 1 teledb (4 rows) null 值记录排在最后。 plaintext teledb select from teledbpg order by nickname nulls last; id nickname + 1 hello,pgxc 3 pg 1 teledb 4 (4 rows) 按拼音排序 使用convert 函数实现汉字按拼音进行排序。 plaintext teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by convert(myname::bytea,'UTF8','GBK'); myname 陈五 李四 张三 (3 rows) 使用convertto 函数实现汉字按拼音进行排序。 plaintext teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by convertto(myname,'GBK'); myname 陈五 李四 张三 (3 rows) 通过指定排序规则collact 来实现汉字按拼音进行排序。 plaintext teledb

select from teledbpg order by md5(nickname); id nickname + 1 hello,pgxc 3 pg 1 teledb (3 rows) 排序也能用子查询。 plaintext teledb select from teledbpg order by (select id from teledbpg order by random() limit 1); id nickname + 1 teledb 1 hello,pgxc 3 pg (3 rows) null 值排序结果处理 plaintext teledb insert into teledbpg values(4,null); INSERT 0 1 null 值记录排在最前面。 plaintext teledb select from teledbpg order by nickname nulls first; id nickname + 4 1 hello,pgxc 3 pg 1 teledb (4 rows) null 值记录排在最后。 plaintext teledb select from teledbpg order by nickname nulls last; id nickname + 1 hello,pgxc 3 pg 1 teledb 4 (4 rows) 按拼音排序 使用convert 函数实现汉字按拼音进行排序。 plaintext teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by convert(myname::bytea,'UTF8','GBK'); myname 陈五 李四 张三 (3 rows) 使用convertto 函数实现汉字按拼音进行排序。 plaintext teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by convertto(myname,'GBK'); myname 陈五 李四 张三 (3 rows) 通过指定排序规则collact 来实现汉字按拼音进行排序。 plaintext teledb

select from teledbpg order by md5(nickname); id nickname + 1 hello,pgxc 3 pg 1 teledb (3 rows) 排序也能用子查询。 plaintext teledb select from teledbpg order by (select id from teledbpg order by random() limit 1); id nickname + 1 teledb 1 hello,pgxc 3 pg (3 rows) null 值排序结果处理 plaintext teledb insert into teledbpg values(4,null); INSERT 0 1 null 值记录排在最前面。 plaintext teledb select from teledbpg order by nickname nulls first; id nickname + 4 1 hello,pgxc 3 pg 1 teledb (4 rows) null 值记录排在最后。 plaintext teledb select from teledbpg order by nickname nulls last; id nickname + 1 hello,pgxc 3 pg 1 teledb 4 (4 rows) 按拼音排序 使用convert 函数实现汉字按拼音进行排序。 plaintext teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by convert(myname::bytea,'UTF8','GBK'); myname 陈五 李四 张三 (3 rows) 使用convertto 函数实现汉字按拼音进行排序。 plaintext teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by convertto(myname,'GBK'); myname 陈五 李四 张三 (3 rows) 通过指定排序规则collact 来实现汉字按拼音进行排序。 plaintext teledb

本章节主要介绍脚本开发功能。 数据中台将不同类型引擎任务封装为不同脚本任务，通过创建脚本来生成数据开发任务。同时，数据开发支持使用资源和函数开发任务。 脚本开发功能提供如下能力： 提供在线脚本编辑器，支持Python脚本、Shell脚本、MySQL脚本、DM（达梦数据库）脚本、Hive脚本、Spark脚本、PySpark脚本、Postgre SQL脚本、Gauss DB脚本、SQLserver脚本、Kingbase脚本、Clickhouse脚本、Oracle脚本等在线代码开发和调测。 支持导入和导出脚本。 支持使用变量和函数。 支持脚本的版本管理能力，支持生成保存版本和提交版本。 脚本开发支持细粒度权限管控，对数据开发脚本目录权限管控策略进行配置。 前提条件 需要完成数据源接入和数据建模，才能进行数据开发操作。 使用限制 已拥有开发角色权限。 已拥有所需数据源和数据表权限。 开发流程 新建脚本：新建相应类型的脚本。 开发脚本：基于新建的脚本，进行脚本的在线开发、调试和执行。。 （可选）管理脚本：脚本开发完成后，您可以根据需要，进行脚本管理。 编排脚本：将脚本按照依赖关系进行编排，同时配置任务调度参数。 发布脚本：将测试通过的脚本发布上线到生产环境。

select from teledbpg order by (select id from teledbpg order by random() limit 1); id nickname + 1 teledb 1 hello,pgxc 3 pg (3 rows) null 值排序结果处理 teledb insert into teledbpg values(4,null); INSERT 0 1 null 值记录排在最前面。 teledb select from teledbpg order by nickname nulls first; id nickname + 4 1 hello,pgxc 3 pg 1 teledb (4 rows) null 值记录排在最后。 teledb select from teledbpg order by nickname nulls last; id nickname + 1 hello,pgxc 3 pg 1 teledb 4 (4 rows) 按拼音排序 使用convert 函数实现汉字按拼音进行排序。 teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by convert(myname::bytea,'UTF8','GBK'); myname 陈五 李四 张三 (3 rows) 使用convertto 函数实现汉字按拼音进行排序。 teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by convertto(myname,'GBK'); myname 陈五 李四 张三 (3 rows) 通过指定排序规则collact 来实现汉字按拼音进行排序。 teledb select from (values ('张三'), ('李四'),('陈五')) t(myname) order by myname collate "zhCN.utf8"; myname 陈五 李四 张三 (3 rows)

本页介绍天翼云TeleDB数据库Oracle语法中的二进制操作函数。 emptyclob 需要加载插件teledbxoraclepackagefunction create extension teledboraclepackagefunction; 初始化CLOB 字段。 teledb select emptyclob(); emptyclob (1 row) teledb create table t1 (f1 int,f2 clob); CREATE TABLE teledb insert into t1(f1,f2) values (1,emptyclob()); INSERT 0 1 teledb

参数 是否必填 参数类型 说明 示例 下级对象 domain 是 String 域名必须属于当前用户且合法有效 ctyun.cn scriptname 是 String 函数脚本名 为264位的小写字母、数字、下划线组合，以小写字母、数字开头结尾 luatest

本页介绍天翼云TeleDB数据库定时任务管理。 操作场景 TeleDB支持对数据库实例执行定时任务，该功能主要通过内置如下函数对数据库实例执行定时任务管理。用户可自行调整对定时任务的执行频率以及查看执行记录。 TeleDB内置了如下函数，所有函数会根据执行频率自动执行任务。 collectdbstatistic：用于数据库实例更新统计信息。 pgcleantwophase：用于数据库实例清理两阶段残留事务。 pgunlockdeadlock：用于处理死锁。 deleteossstatistics：用于删除配置库存储过期的节点监控数据。 deleteslowquery：用于删除过期的慢日志数据。 deleteerrlog：用于删除过期的错误日志数据。 checkxlogbkp：用于检查备份的增量日志的连续性。 deleteaudit：用于删除管控配置库中过期的审计日志数据。 checkfgaaudit：用于检查细粒度审计是否采集到数据。 deletehighfrequencyquery：用于删除管控配置库中存储过期的高频SQL数据。 deletesnapshot：用于删除管控的实例配置库中存储过期的实例运行快照数据。 queryindexadvice：用于对慢sql查询生成相应的索引优化建议。 操作步骤 1. 切换至TeleDB控制台，在左侧导航单击实例列表。 2. 单击目标实例所在行的详情 ，进入实例详情页面。 3. 进入实例详情页面，单击定时任务 。 4. 您可通过控制定时任务开关管理是否定时执行该任务。 5. 单击实例详情操作列的配置 ，出现配置执行频率对话框。 6. 在配置执行频率对话框，输入频率 和周期 ，单击确定 ，完成执行频率的修改。 7. 单击历史记录可以查看以往执行该任务详情。 8. 单击立即执行 ，出现提示信息对话框。 9. 在提示对话框中，单击确定可立即执行定时任务。

本页面介绍从ClickHouse 自建集群迁移数据。 前提条件 1. 创建了目标云数据库ClickHouse实例。详细的操作步骤，请参考创建实例。 2. 创建了用于目标云数据库ClickHouse集群的数据库账号和密码。详细的操作步骤，请参考创建账号。 3. 确保创建的云数据库ClickHouse实例可以访问ClickHouse自建集群。 4. 确保自建ClickHouse集群与创建的云数据库ClickHouse实例具有相同的表结构。 使用 remote 函数进行数据迁移的详细示例 以下是使用云数据库ClickHouse的 remote函数在ClickHouse集群之间迁移数据的详细示例： 假设两个ClickHouse集群：源集群（sourcecluster）和目标集群（targetcluster），它们都具有相同的表结构。 1. 在目标集群中创建接收数据的表： sql CREATE TABLE targetdatabase.targettable ( id UInt64, name String ) ENGINE MergeTree ORDER BY id; 2. 在源集群中执行查询，并使用 remote函数将查询结果插入到目标集群的表中： sql INSERT INTO remote('clickhouse://targetcluster', targetdatabase.targettable) SELECT id, name FROM sourcedatabase.sourcetable; 在上述查询中，从源集群的 sourcetable中选择 id和 name列，并将数据插入到目标集群的 targettable中。 clickhouse://targetcluster：替换为目标集群的连接URL。 targetdatabase.targettable：替换为目标集群中接收数据的数据库和表名称。 sourcedatabase.sourcetable：替换为源集群中要迁移数据的数据库和表名称。 3. 运行上述查询后，源集群将执行查询，并将查询结果插入到目标集群的表中。这样，数据就从源集群迁移到目标集群的表中。 确保源集群和目标集群之间具有网络连接，并且能够相互访问。在执行数据迁移操作时，请考虑网络带宽、延迟和数据量等因素，并确保系统资源足够支持数据迁移过程。 说明 上述示例仅展示了迁移数据的基本原理，具体的表结构和查询逻辑可能因实际情况而异，需要根据实际需求进行相应的调整和配置。

定时触发器 定时触发器能够依照您预设的确切时刻或周期性指令，自动启动函数的运行，这为您提供了一种灵活的方式来安排任务的执行，特别适合那些需要按计划重复执行任务的场景。 使用场景 定时触发器非常灵活，适用于各种时间相关的场景，例如： 周期性任务，例如每周五发送运维报表。 定时任务，例如设定在指定日期时间开启游戏活动。 触发消息格式 触发消息: javascript { "msg": "hello world!" } 对应触发时的工作流输入: plaintext { "msg": "hello world!" } 操作步骤 1. 登录工作流控制台，点击目标工作流，进入工作流详情详情。 2. 在配置选项卡中，选择左边的 工作流调度 选项卡。 3. 点击 创建工作流调度 ，在弹出的右抽屉中选择 定时触发器，配置参数解释如下表。 配置项 参数说明 示例 名称 工作流调度的名称 timeTicker 触发方式 根据需要选择触发方式： 时间间隔：触发器每隔n分钟触发一次函数执行。 指定时间：选择时区，并指定日期、星期和时间，触发器在某时区的指定时间触发一次函数执行。 自定义：支持秒级配置，使用6段式Cron表达式，兼容Quartz的表达式。 /5 触发消息 该消息内容将会作为工作流的输入，必须为JSON字段。 { "msg" : "hello world!" }

本页介绍天翼云TeleDB数据库Oracle语法中的二进制操作函数。 emptyclob 需要加载插件teledbxoraclepackagefunction plaintext create extension teledboraclepackagefunction; 初始化CLOB 字段。 plaintext teledb select emptyclob(); emptyclob (1 row) teledb create table t1 (f1 int,f2 clob); CREATE TABLE teledb insert into t1(f1,f2) values (1,emptyclob()); INSERT 0 1 teledb

本章节主要介绍查看数据库审计日志。 前提条件 审计功能总开关auditenabled已开启。（auditenabled默认值为ON，若关闭请参考修改数据库参数设置为ON）。 已配置需要审计的审计项。各审计项及其开启办法，请参考设置数据库审计日志。 数据库正常运行，并且对数据库执行了一系列增、删、改、查操作，保证在查询时段内有审计结果产生。 数据库各个节点审计日志单独记录。 只有拥有AUDITADMIN属性的用户才可以查看审计记录。 查看数据库审计日志方式 方式一：由于审计日志会占用一定磁盘空间，为了防止本地磁盘文件过大，DWS支持审计日志转储，用户可以开启“开启审计日志转储”功能，将审计日志转储到OBS（用户需创建用于存储审计日志的OBS桶）中进行查看或下载，详细内容请参考转储数据库审计日志章节的 查看审计日志转储记录。 方式二：通过依赖于云日志服务LTS的“集群日志管理”功能查看采集的审计数据库日志或进行日志下载，详细内容请参考集群日志管理查看集群日志。 方式三：数据库的审计日志默认存储于数据库中，连接集群后，使用pgqueryaudit函数进行查看。详细内容请参考下方 使用pgqueryaudit函数查看数据库审计日志。 使用pgqueryaudit函数查看数据库审计日志 1. 使用SQL客户端工具成功连接集群，连接方式请参考连接集群。 2. 使用函数pgqueryaudit查询当前CN节点的审计日志，其语法为： pgqueryaudit(timestamptzstartime ,timestamptz endtime , auditlog ) 参数startime和endtime分别表示审计记录的开始时间和结束时间，auditlog表示所查看的审计日志信息所在的物理文件路径，当不指定auditlog时，默认查看连接当前实例的审计日志信息。 例如，查看指定时间段当前CN节点审计记录。 SELECT FRO Mpgqueryaudit(' 20210223 21:49:00 ',' 2021022321:50:00'); 查询结果如下： begintime endtime operationtype audittype result username database clientconninfo objectname commandtext detailinfo transactionxid queryid nodename threadid localport remoteport +++ ++++++ ++ +++++ q 20210223 21:49:57.76+08 20210223 21:49:57.82+08 loginlogout userlogin ok dbadmin gaussdb gsql@[local] gaussdb login db login db(gaussdb) successfully, the current user is: dbadmin 0 0 coordinator1 140324035360512@667403397820909 27777 该条记录表明，用户dbadmin在20210223 21:49:57.82+08登录数据库gaussdb。其中clientconninfo字段在loghostname启动且IP连接时，字符@后显示反向DNS查找得到的主机名。 3. 使用函数pgxcqueryaudit可以查询所有CN节点的审计日志，其语法为： pgxcqueryaudit(timestamptz startime,timestamptzendtime ) 例如，查看指定时间段所有CN节点审计记录。 ELECT FROM pgxcqueryaudit('20210223 22:05:00','20210223 22:07:00') where audittype 'userlogin' and username 'user1'; 查询结果如下： begintime endtime operationtype audittype result username database clientconninfo objectname commandtext detailinfo transactionxid queryid nodename threadid localport remoteport +++ ++++++ ++ ++++ 20210223 22:06:22.219+08 20210223 22:06:22.271+08 loginlgout userlogin ok user1 gaussdb gsql@[local] gaussdb login db 20221125 233 login db(gaussdb) successfully, the current user is: user1 0 0 coordinator2 140689577342720@667404382271356 27782 20210223 22:05:51.697+08 20210223 22:05:51.749+08 loginlgout userlogin ok user1 gaussdb gsql@[local] gaussdb login db login db(gaussdb successfully, the current user is: user1 0 0 coordinator1 140525048424192@667404351749143 27777 查询结果显示，用户user1在CN1和CN2的成功登录记录。

本文介绍函数运行时的FetchEvent的定义与用法。 分配给运行时的HTTP请求的事件类型。详细定义请参见MDN官方文档FetchEvent。 上下文 javascript addEventListener("fetch", event > { event.respondWith(handleRequest(event)) }) 属性 event.request Request 触发FetchEvent的HTTP请求。 方法 当运行时脚本收到请求时，运行时将触发FetchEvent，然后触发事件类型为fetch事件侦听器进行处理。事件处理程序可以调用event对象的以下方法来进行控制： event.respondWith( response RequestPromise ) void 拦截请求并发送自定义响应。 必须调用respondWith()进行有效的响应，否则运行时会报错。 生命周期 当边缘接收到一个请求，该请求的URL映射到用户函数时，FetchEvent生命周期开始；这时运行时触发一个事件，并创建一个FetchEvent对象传递给运行时的第一个注册为fetch的事件处理程序。 事件处理程序可以使用respondWith()来拦截请求并允许用户发送自定义响应。 如果fetch事件处理程序未调用respondWith()，则运行时会将事件传递到下一个注册的fetch事件处理程序。 javascript addEventListener('fetch', (event) > { event.respondWith(handle(event)); }); async function handle(event) { // 1.异步发起一个fetch请求，但是我们不使用await，所以该请求会并行执行 fetch(" // 2.立刻发起回复。这个回复hello world发回给客户端时，前面发起的fetch可能没有执行完毕。 return "hello world"; } 相关参考 示例代码：返回HTML页面 示例代码：返回JSON内容

本页介绍天翼云TeleDB数据库语句行为相关参数。 searchpath (string) 这个变量指定当一个对象（表、数据类型、函数等）被用一个无模式限定的简单名称引用时，用于进行搜索该对象的模式顺序。当在不同模式中有同名对象时，将使用第一个在搜索路径中被找到的对象。一个不属于搜索路径中任何一个模式的对象只能通过用限定名（带点号）指定包含它的模式来引用。searchpath的值必需是一个逗号分隔的模式名列表。任何不是一个已有模式的名称，或者是一个用户不具有USAGE权限的模式，将被安静地忽略。如果列表项之一是特殊名user，则具有SESSIONUSER返回的名字的模式将取代它（如果有这样一个模式并且该用户有该模式的USAGE权限；如果没有，user会被忽略）。系统目录模式pgcatalog总是被搜索，不管它是否在搜索路径中被提及。如果它在路径中被提及，那么它将被按照路径指定的顺序搜索。如果pgcatalog不在路径中，则它将在任何路径项之前 被搜索。同样，当前会话的临时表模式pgtempnnn也总是被搜索（如果存在）。它可以在路径中通过使用别名pgtemp显式列出。如果在路径中没有列出，那么会首先对它进行搜索（甚至是在pgcatalog之前）。然而，临时模式只被用来搜索关系（表、视图、序列等）和数据类型名。它从不用于搜索函数或操作符名。当对象创建时没有指定一个特定目标模式，它们将被放置在searchpath中第一个合法模式中。如果搜索路径为空将报告一个错误。这个参数的缺省值是"$user", public。这种设置支持一个数据库（其中没有用户拥有私有模式，并且所有人共享使用public）、每个用户私有模式及其组合的共享使用。其它效果可以通过全局或者针对每个用户修改默认搜索路径设置获得。搜索路径的当前有效值可以通过SQL函数currentschemas检查。它和检查searchpath的值不太一样，因为currentschemas显示出现在searchpath中的项如何被解析。