本文介绍如何在Node.js运行环境下打印和查看函数日志。 打印日志 当需要查看函数运行相关的自定义状态时，可以使用如下几种方式打印日志至标准输出stdout。往标准输出stdout打印的日志内容会被函数收集。 ES模块 export const handler async (event, context) > { process.stdout.write('hi,fcn'); console.log('hello,world'); context.logger.info('hello,fc'); return "Hello World!"; }; CommonJS模块 'use strict'; exports.handler (event, context, callback) > { process.stdout.write('hi,fcn'); console.log('hello,world'); context.logger.info('hello,fc'); callback(null, 'hello,world'); }; 以下分别介绍所使用的几种日志打印方法。 使用process.stdout.write打印日志 使用此方法打印日志会将内容原样输出到日志中。输出的日志内容如下所示。 hi,fc 使用console.log打印日志 使用此方法打印的每条日志中都会包含时间、RequestId、日志级别等信息。输出的日志内容如下所示。 20240304 07:01:16.927 165e571bc158a59e8b63f98cd471c [info] hello,world 直接使用context.logger打印日志 当您配置的函数实例并发度大于1时，一个函数实例会同时并发处理多个请求。此时强烈建议使用context.logger打印日志，以通过RequestId区分各并发请求的日志。输出的日志内容如下所示。 20240304 07:01:16.927 165e571bc158a59e8b63f98cd471c [[object Object]] hello,fc 查看日志 函数执行完成后，您可以在函数详情页的日志页签查看日志信息。

本章介绍如何管理函数流执行历史记录 执行历史查询 1. 登录FunctionGraph控制台，在左侧导航栏选择“函数流”，进入“函数流”页面。 2. 在“函数流”流程列表页面，单击需要查看执行历史的流程，进入流程详情页面。 3. 切换至“运行记录”页签，查看执行历史运行记录。 4. 左侧为执行历史记录列表，展示最近100次执行记录，支持根据流程执行ID进行查询。 单击左侧的执行记录，中间画布展示流程的执行结果，如果节点执行成功，图标背景为绿色，如果执行失败背景为红色。 执行失败 画布下方输入输出展示区默认展示流程的输入和输出，点击上方任意节点，展示节点的输入和输出。 说明 对于函数流及函数流各个节点，若输出值中有字段的值为null，则该字段会被直接过滤，不予展示。 最下方日志展示流程从开始到结束所有节点的执行记录。 失败流程重试 1. 登录FunctionGraph控制台，在左侧导航栏选择“函数流”，进入“函数流”页面。 2. 在“函数流”流程列表页面，单击需要查看执行历史的流程，进入流程详情页面。 3. 切换至“运行记录”页签，查看执行历史运行记录。 4. 在失败的记录右侧单击重试图标，重试成功后会生成一条执行记录。

您可以通过本页了解天翼云TeleDB数据库的建立函数语法、[OR REPLACE] 更新函数介绍、[模式名.]函数名介绍。 建立函数语法 plaintext CREATE [OR REPLACE] FUNCTION [模式名.]函数名 ([参数模式 [参数名] 数据类型 [default 默认值] [,…]]) RETRUNS [SETOF] 数据类型 AS [标签] [DECLARE 变量定义] BEGIN 注释 /注释/ 语句执行 END; [标签] LANGUAGE PLPGSQL; [OR REPLACE] 更新函数介绍 OR REPLACE 的作用为函数存在时则替换，建立 PL/pgsql 函数时如果不带 OR REPLACE 关键字， 则遇到函数已经存在，系统会报错，如下所示： plaintext teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb CREATE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; ERROR: function "f" already exists with same argument types teledb CREATE OR REPLACE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; CREATE FUNCTION teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb select f(); NOTICE: Hello ,teledb f (1 row) [模式名.]函数名介绍 建立函数名称，模式名可以指定，也可以不指定，不指存则存放在当前模式下，如上面例子就没有指定模式名，则就存放在当前模式下，如下所示： plaintext teledb select from pgnamespace; nspname nspowner nspacl ++ pgtoast 10 pgoracle 10 squeeze 10 pgtemp1 10 pgtoasttemp1 10 pgcatalog 10 {teledbUC/teledb,U/teledb} public 10 {teledbUC/teledb,UC/teledb} informationschema 10 {teledbUC/teledb,U/teledb} (8 rows) teledb

您可以通过本页了解天翼云TeleDB数据库的建立函数语法、[OR REPLACE] 更新函数介绍、[模式名.]函数名介绍。 建立函数语法 plaintext CREATE [OR REPLACE] FUNCTION [模式名.]函数名 ([参数模式 [参数名] 数据类型 [default 默认值] [,…]]) RETRUNS [SETOF] 数据类型 AS [标签] [DECLARE 变量定义] BEGIN 注释 /注释/ 语句执行 END; [标签] LANGUAGE PLPGSQL; [OR REPLACE] 更新函数介绍 OR REPLACE 的作用为函数存在时则替换，建立 PL/pgsql 函数时如果不带 OR REPLACE 关键字， 则遇到函数已经存在，系统会报错，如下所示： plaintext teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb CREATE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; ERROR: function "f" already exists with same argument types teledb CREATE OR REPLACE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; CREATE FUNCTION teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb select f(); NOTICE: Hello ,teledb f (1 row) [模式名.]函数名介绍 建立函数名称，模式名可以指定，也可以不指定，不指存则存放在当前模式下，如上面例子就没有指定模式名，则就存放在当前模式下，如下所示： plaintext teledb select from pgnamespace; nspname nspowner nspacl ++ pgtoast 10 pgoracle 10 squeeze 10 pgtemp1 10 pgtoasttemp1 10 pgcatalog 10 {teledbUC/teledb,U/teledb} public 10 {teledbUC/teledb,UC/teledb} informationschema 10 {teledbUC/teledb,U/teledb} (8 rows) teledb

计算 弹性云主机服务等级协议 天翼云物理机服务等级协议 天翼云弹性伸缩服务等级协议 天翼云云迁移服务等级协议 天翼云函数工作流服务等级协议 天翼云轻量型云主机服务等级协议 天翼云云骁智算服务等级协议 存储 天翼云对象存储服务等级协议 天翼云弹性文件服务等级条款 天翼云硬盘服务等级条款 天翼云云备份服务等级条款 天翼云云容灾服务等级条款 天翼云并行文件HPFS服务等级协议 天翼云海量文件OceanFS服务等级协议 天翼云混合存储网关服务等级协议 云硬盘备份服务等级协议 天翼云弹性容器实例服务等级协议

新建函数 1. 在函数上右键 ，选择新建函数 ，打开新建函数页面。 2. 在页面按要求输入函数名、函数的入参、函数的返回值类型、函数定义等信息后，点击提交按钮即可创建函数。 新建事件 1. 在事件上右键 ，选择新建事件 ，打开新建事件页面。 2. 在页面按要求输入事件名、事件定义等信息后，点击提交按钮即可创建事件。 新建触发器 1. 在触发器上右键 ，选择新建触发器 ，打开新建触发器页面。 2. 在页面按要求输入触发器名称、触发表、触发时机、触发事件、触发器定义等信息后，点击提交按钮即可创建触发器。 编辑可编程对象 说明 以编辑视图为例，其他可编程对象操作类似。 1. 在视图名称上右键 ，选择编辑视图 ，打开编辑视图页面。 2. 可以对视图名称、视图定义等进行修改，修改完成后，点击提交按钮即可。 删除可编程对象 说明 以删除视图为例，其他可编程对象操作类似。 在视图名称上右键 ，选择删除视图 操作，在删除确认弹窗上点击确定按钮即可。

视频 天翼云媒体存储系统服务协议 企业中间件 天翼云分布式消息服务协议 软件开发生产线CodeArts服务协议 容器与微服务 天翼云云容器引擎服务协议 天翼云容器实例产品服务协议 天翼云Serverless容器服务产品服务协议 容器镜像产品服务协议 天翼云微服务云应用平台服务协议 微服务引擎产品服务协议 天翼云应用编排服务协议 天翼云应用服务网格服务协议 天翼云EasyCoding敏捷开发平台服务协议 天翼云翼飞低代码平台服务协议 天翼云应用性能监控APM服务协议 天翼云容器安全卫士服务协议 天翼云函数计算服务协议

云日志服务支持单位转换函数。 函数列表 函数名称 语法 说明 cast cast(x, type) 用于转换x的数据类型。 cast函数 用于转换x的数据类型。 语法 cast(x, type) 参数说明 参数名称 说明 类型 是否必选 x 参数值可以为任意类型。 是 type SQL数据类型，可选值为bigint、varchar、double、boolean、datetime string 是 返回值类型 string 示例 类型 示例 统计分析语句 select cast('1', 'bigint') 返回结果

本文简述异步处理相关函数的语法、作用、入参、返回值、示例。 ctyun.thread.run 函数信息详见下表： 项目 描述 语法 result，err ctyun.thread.run(callback, arg1, arg2, ...) 作用 创建一个线程， 异步执行lua函数。主要使用场景为异步通知远端处理结果，不阻塞正常的业务流程。 入参 callback 为lua函数，arg1,arg2,...为lua函数的参数。 返回值 创建成功返回true，失败返回false，以及错误信息err。 注意 由于是独立的线程执行callback，跟正常的业务请求是独立的环境。在callback中不能使用跟请求属性相关的函数（ctyun.req和ctyun.resp以及ctyun.var)。如果需要用到相关的变量，请通过arg1,arg2,...参数传进去。 示例： stata local function test(url, body) local res, err ctyun.queryremote(url, { method "POST", body body, headers { ["ContentType"] "application/xwwwformurlencoded", }, }, 30000) if err then return end end ctyun.thread.run(test, " "test bodyyyyyyy") ctyun.resp.setoutput("hello world") 结果：hello world

本文简述异步处理相关函数的语法、作用、入参、返回值、示例。 ctyun.thread.run 函数信息详见下表： 项目 描述 语法 result，err ctyun.thread.run(callback, arg1, arg2, ...) 作用 创建一个线程， 异步执行lua函数。主要使用场景为异步通知远端处理结果，不阻塞正常的业务流程。 入参 callback 为lua函数，arg1,arg2,...为lua函数的参数。 返回值 创建成功返回true，失败返回false，以及错误信息err。 注意 ：由于是独立的线程执行callback，跟正常的业务请求是独立的环境。在callback中不能使用跟请求属性相关的函数（ctyun.req和ctyun.resp以及ctyun.var)。如果需要用到相关的变量，请通过arg1,arg2,...参数传进去。 示例： stata local function test(url, body) local res, err ctyun.queryremote(url, { method "POST", body body, headers { ["ContentType"] "application/xwwwformurlencoded", }, }, 30000) if err then return end end ctyun.thread.run(test, " "test bodyyyyyyy") ctyun.resp.setoutput("hello world") 结果：hello world

本文介绍地理函数的基本语法及示例。 函数列表 函数名称 语法 说明 geohash geohash(x, y [, precision]) 对经度和纬度进行geohash编码。 geohash函数 对经度和纬度进行geohash编码。 语法 plaintext geohash(x,;y[, precision]) 参数说明 参数名称 说明 类型 是否必选 x 经度。取值范围[180°, 180°] float类型 是 y 纬度。取值范围[90°, 90°] float类型 是 precision 精度，或Base32编码长度。取值范围[1, 12]，默认为12 integer类型 否 返回值类型 string类型 示例 类型 示例 统计分析语句 返回结果 wtw2kg3s54y7

本章节主要指导使用Springboot开发应用的用户，部署业务到FunctionGraph。用户通常可以使用SpringInitializr或者IntelliJ IDEA新建等多种方式构建SpringBoot，本章节以Spring.io 的 操作流程 将既有项目部署到FunctionGraph通常只需要：修改项目监听端口号为8000，然后在jar包同目录创建bootstrap文件写入执行jar包的命令。本案例使用IntelliJIDEA，Maven项目。 构建代码包 1. 打开Springboot项目，在maven插件处单击package，生成jar包。 图 生成jar包 2. 配置工程web端口。HTTP函数当前支持8000端口，需配置工程web端口为 8000 （此端口请勿修改） ,可以使用application.properties文件来配置，也可以在启动时指定端口号。 图 配置8000端口 3. 在jar包同目录创建bootstrap文件，输入启动参数：/opt/function/runtime/java11/rtsp/jre/bin/javajar Dfile.encodingutf8/opt/function/code/restservicecomplete0.0.1SNAPSHOT.jar 图 输入启动参数 4. 选中jar包和bootstrap文件，打包成zip包。 创建HTTP函数并上传代码 创建1个HTTP函数，并上传已打包的zip包。请参见用户指南的“创建HTTP函数”章节。 验证结果 1. 使用函数测试事件验证 1. 在函数详情页，选择函数版本，单击“配置测试事件”，弹出“配置测试事件”页。 2. 选择事件模板，修改测试事件中的path、pathParameters参数，构建一个简单的Get请求。 3. 单击“创建”，完成测试事件创建。 4. 单击“测试”，获取响应。 2. 配置APIG（专享版）触发器测试 1. 请参见 用户指南的“使用APIG（专享版）触发器”章节，创建APIG（专享版）触发器，“安全认证”建议选择“None”，方便调试。 2. 复制生成的调用URL在浏览器进行访问。在URL后添加请求参数greeting?namefguser。默认生成的APIG（专享版）触发器的调用URL为“域名/函数名”，在本案例中即： 如果用户直接把已有的工程上传，会因为path里多了函数名而无法直接访问自己的服务。

本文介绍函数运行时的addEventListener定义与用法。 此函数定义执行用户函数脚本的触发器。addEventListener仅支持注册一个事件监听器。当前仅支持fetch请求事件，通过注册fetch事件监听器，生成HTTP请求事件FetchEvent，进而实现对HTTP请求的处理。 定义 javascript addEventListener(type: string, listener: (event: FetchEvent) > void): void; 说明 如果注册多个"fetch"类型的监听器，当一个监听器未调用时event.respondWith()，运行时会将事件传递给下一个已注册的监听器。 如果对某个事件进行多次调用会形成调用链条。当某个回调函数调用respondWith函数时，调用链条会被终止，后面注册的回调函数不会再被调用。 参数 type string 事件类型，当前仅支持"fetch"，后续会支持"scheduled"。 listener function 事件监听器。用于处理事件回调。 示例 javascript // 注册请求事件监听器 addEventListener("fetch", event > { // 响应客户端请求 return event.respondWith( new Response("Hello world") ) }) 相关参考 示例代码：返回HTML页面 示例代码：返回JSON内容

本文介绍函数运行时的addEventListener定义与用法。 此函数定义了执行用户函数脚本的触发器。addEventListener仅支持注册一个事件监听器。当前仅支持fetch请求事件，通过注册fetch事件监听器，生成HTTP请求事件FetchEvent，进而实现对HTTP请求的处理。 定义 javascript addEventListener(type: string, listener: (event: FetchEvent) > void): void; 说明 如果注册了多个"fetch"类型的监听器，当一个监听器未调用时event.respondWith()，运行时会将事件传递给下一个已注册的监听器。 如果对某个事件进行多次调用会形成调用链条。当某个回调函数调用了respondWith函数时，调用链条会被终止，后面注册的回调函数不会再被调用。 参数 type string 事件类型，当前仅支持"fetch"，后续会支持"scheduled"。 listener function 事件监听器。用于处理事件回调。 示例 javascript // 注册请求事件监听器 addEventListener("fetch", event > { // 响应客户端请求 return event.respondWith( new Response("Hello world") ) }) 相关参考 示例代码：返回HTML页面 示例代码：返回JSON内容

本文介绍IP地址转换函数的基本语法及示例。 函数列表 函数名称 语法 说明 inetaton inetaton(x) 把ip转为无符号整型。 inetntoa inetntoa(x) 把无符号整型的ip转为字符串式的地址。 inetaton函数 把ip转为无符号整型。 语法 plaintext inetaton(x) 参数说明 参数名称 说明 类型 是否必选 x 需要转换的参数 string类型 是 返回值类型 unsigned int类型 示例 类型 示例 统计分析语句 返回结果 2130706433 inetntoa函数 把无符号整型的ip转为字符串式的地址。 语法 plaintext inetntoa(x) 参数说明 参数名称 说明 类型 是否必选 x 需要转换的参数 unsigned int类型 是 返回值类型 string类型 示例 类型 示例 统计分析语句 返回结果 127.0.0.1

云日志服务提供手机号号码函数，用于获取手机号的运营商，归属省份以及归属城市。 函数列表 函数名称 语法 说明 mobilecarrier mobilecarrier(x) 获取手机号号码运营商。 mobilecity mobilecity(x) 获取手机号号码运所属城市。 mobileprovince mobileprovince(x) 获取手机号号码运所属省份。 mobilecarrier函数 获取手机号号码运营商。 语法 mobilecarrier(x) 参数说明 参数名称 说明 类型 是否必选 x 手机号号码 string类型 是 返回值类型 string 示例 类型 示例 统计分析语句 select mobilecarrier('18922732377') 返回结果 mobilecity函数 获取手机号号码运所属城市。 语法 mobilecity(x) 参数说明 参数名称 说明 类型 是否必选 x 手机号号码 string类型 是 返回值类型 string类型 示例 类型 示例 统计分析语句 select mobilecity('18922732377') 返回结果 mobileprovince函数 获取手机号号码运所属省份。 语法 mobileprovince(x) 参数说明 参数名称 说明 类型 是否必选 x 手机号号码 string类型 是

本章主要介绍创建自定义认证。 操作场景 自定义认证包含两种认证：前端自定义认证和后端自定义认证。 前端自定义认证：如果您希望使用自己的认证系统，而不是APP认证/IAM认证对API的访问进行认证鉴权时，您可以使用自定义认证，通过您自定义的函数进行认证鉴权。 后端自定义认证：当不同的后端服务使用不同的认证系统时，导致您需要为不同的认证系统定制化开发API，而APIG通过自定义认证功能，将多种认证系统集成，简化API开发的复杂度。您只需要在APIG中创建自定义的函数认证，APIG通过此函数对接后端认证系统，获取后端服务的访问授权。 说明 自定义认证依赖函数工作流服务。如果当前Region没有上线函数工作流服务，则不支持使用自定义认证。 使用自定义认证调用API的流程如下图所示： 图 使用自定义认证调用API 前提条件 已在函数工作流服务中完成函数创建。 创建自定义认证 步骤 1 进入API网关控制台页面。 步骤 2 根据实际业务在左侧导航栏上方选择实例。 步骤 3 在左侧导航栏选择“API管理 > API策略”。 步骤 4 在“自定义认证”页面，单击“创建自定义认证”。 配置自定义认证参数。 表 自定义认证参数说明 信息项 描述 认证名称 您自定义的认证名称，用于区分不同的自定义认证。 类型 前端：对API的访问进行认证鉴权。 后端：对后端服务的访问授权。 函数地址 选择在FunctionGraph中创建的函数。 版本或别名 选择函数的版本或别名。 缓存时间(秒) 设置认证结果缓存的时间。 值为0时代表不缓存，最大支持3600秒。 身份来源 设置用于认证的请求参数。 当“类型”为“前端”，且“缓存时间”不为0时，必须设置此参数。使用缓存时，此参数将作为搜索条件来查询认证结果。 是否发送body 指是否将API请求的body体内容传递给认证函数。body体内容传给函数的方式，与header、query内容传递一致。 用户数据 您自定义的请求参数，APIG调用函数时，与“身份来源”一同作为请求参数。 步骤 5 单击“确定”，完成自定义认证的创建。

项目 描述 语法 ctyun.req.enrollheaderback(callbackfunc, ...) 作用 在收到响应头时会回调callbackfunc函数。 入参 callbackfunc: function。回调函数 ... : 回调函数的入参：其他任意类型。入参个数可以是不定的。 返回值 无。

项目 描述 语法 ctyun.req.enrollheaderback(callbackfunc, ...) 作用 在收到响应头时会回调callbackfunc函数。 入参 callbackfunc: function。回调函数 ... : 回调函数的入参：其他任意类型。入参个数可以是不定的。 返回值 无。

如果您需要对您所拥有的FunctionGraph进行精细的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），通过IAM，您可以： 根据企业的业务组织，在您的帐号中，给企业中不同职能部门的员工创建IAM用户，让员工拥有唯一安全凭证，并使用FunctionGraph资源。 根据企业用户的职能，设置不同的访问权限，以达到用户之间的权限隔离。 将FunctionGraph资源委托给更专业、高效的其他帐号或者云服务，这些帐号或者云服务可以根据权限进行代运维。 如果帐号已经能满足您的要求，不需要创建独立的IAM用户，您可以跳过本章节，不影响您使用FunctionGraph服务的其它功能。 本章节为您介绍对用户授权的方法，操作流程如下图所示。 前提条件 给用户组授权之前，请您了解用户组可以添加的FunctionGraph权限，并结合实际需求进行选择。 实例流程 1. 在IAM控制台创建用户组，并授予FunctionGraph查询及调用权限“FunctionGraph Invoker”。 2. 在IAM控制台创建用户，并将其加入步骤1中创建的用户组。 3. 新创建的用户登录管理控制台，验证FunctionGraph的函数查询权限。 1. 在“服务列表”中选择“函数工作流 FunctionGraph”，进入“函数 > 函数列表”，单击“创建函数”进入到创建函数界面，发现无法创建函数，表示“FunctionGraph Invoker”已生效。 2. 在“服务列表”中选择除FunctionGraph外的任一服务，若提示权限不足，表示“FunctionGraph Invoker”已生效。

本文主要介绍云日志服务中的数据加工常见问题。 基本语法错误 问题：编写了不符合日志加工 DSL语法的加工规则，例如：多或者少写括号、逗号（,），漏打回车符等。 排查方法：通过加工预览检测语法错误，页面会提示SyntaxError等错误信息。 非法运算符 问题：日志加工DSL中所有的操作都需要通过 DSL提供的函数来完成。比如数值运算、比较等操作都需要通过op函数完成，而不能直接使用python运算符。 排查方法：通过加工预览检测运算符等错误；可将算术运算符和比较操作符等运算符替换为DSL提供的函数完成。 调用不存在的函数 问题：调用了不存在的函数，通过加工预览即可检测出来，并提示unknown function。 排查方法：通过加工预览即可检测出是否调用了不存在的函数；建议检查是否拼写错误。 函数参数传递错误 问题：参数类型错误或参数个数错误等，加工预览会有错误结果输出，比如TypeError、ValueError、"xx takes at least x arguments (xx given)"等。 排查方法：通过加工预览和构造测试日志发现参数传递问题。

响应示例 成功 { "tunnelState": { "status": 1 } } 4.5.查询隧道状态 函数介绍 (void)getTunnelStatus:(TrustCompletion Nullable)completion; 函数用于注册零信任SDK的全局回调。 请求 参数列表 参数 参数类型 参数含义 是否必传 备注 请求示例 [LXRVPNSDKClient getTunnelStatus:^(NSDictionary Nullable response) { self.skipBtn.text [self jsonStringFromDictionary:response]; }]; 响应 参数列表 参数 参数类型 参数含义 是否必传 备注 status NSNumber 隧道状态 是 1｜2｜3｜ 断开｜连接中 ｜已连上 响应示例 成功 { "status": 1 } 4.6.分享日志 函数介绍 (void)SdkShareLog; 函数用于获取日志的存储路径。 请求 参数列表 参数 参数类型 参数含义 是否必传 备注 请求示例 { } 响应 参数列表 参数 参数类型 参数含义 是否必传 备注 无 NSString 日志路径 是 返回日志的路径 响应示例 成功 4.7.获取日志路径 函数介绍 (NSArray)SdkGetLogPath; 函数用于获取日志的存储路径。

您可以通过本页了解天翼云TeleDB数据库的应用程序语法。 建立函数语法 plaintext CREATE [OR REPLACE] FUNCTION [模式名.]函数名 ([参数模式 [参数名] 数据类型 [default 默认值] [,…]]) RETRUNS [SETOF] 数据类型 AS [标签] [DECLARE 变量定义] BEGIN 注释 /注释/ 语句执行 END; [标签] LANGUAGE PLPGSQL; [OR REPLACE] 更新函数介绍 OR REPLACE 的作用为函数存在时则替换，建立 PL/pgsql 函数时如果不带 OR REPLACE 关键字， 则遇到函数已经存在，系统会报错，如下所示： plaintext teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb CREATE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; ERROR: function "f" already exists with same argument types teledb CREATE OR REPLACE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; CREATE FUNCTION teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb select f(); NOTICE: Hello ,teledb f (1 row) [模式名.]函数名介绍 建立函数名称，模式名可以指定，也可以不指定，不指存则存放在当前模式下，如上面例子就没有指定模式名，则就存放在当前模式下，如下所示： plaintext teledb select from pgnamespace; nspname nspowner nspacl ++ pgtoast 10 pgoracle 10 squeeze 10 pgtemp1 10 pgtoasttemp1 10 pgcatalog 10 {teledbUC/teledb,U/teledb} public 10 {teledbUC/teledb,UC/teledb} informationschema 10 {teledbUC/teledb,U/teledb} (8 rows) teledb

您可以通过本页了解天翼云TeleDB数据库的应用程序语法。 建立函数语法 plaintext CREATE [OR REPLACE] FUNCTION [模式名.]函数名 ([参数模式 [参数名] 数据类型 [default 默认值] [,…]]) RETRUNS [SETOF] 数据类型 AS [标签] [DECLARE 变量定义] BEGIN 注释 /注释/ 语句执行 END; [标签] LANGUAGE PLPGSQL; [OR REPLACE] 更新函数介绍 OR REPLACE 的作用为函数存在时则替换，建立 PL/pgsql 函数时如果不带 OR REPLACE 关键字， 则遇到函数已经存在，系统会报错，如下所示： plaintext teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb CREATE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; ERROR: function "f" already exists with same argument types teledb CREATE OR REPLACE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; CREATE FUNCTION teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb select f(); NOTICE: Hello ,teledb f (1 row) [模式名.]函数名介绍 建立函数名称，模式名可以指定，也可以不指定，不指存则存放在当前模式下，如上面例子就没有指定模式名，则就存放在当前模式下，如下所示： plaintext teledb select from pgnamespace; nspname nspowner nspacl ++ pgtoast 10 pgoracle 10 squeeze 10 pgtemp1 10 pgtoasttemp1 10 pgcatalog 10 {teledbUC/teledb,U/teledb} public 10 {teledbUC/teledb,UC/teledb} informationschema 10 {teledbUC/teledb,U/teledb} (8 rows) teledb

本章介绍函数工作流在同步调用或异步调用执行失败时如何重试。 函数在同步调用或异步调用执行失败时，您可以参见以下重试机制进行操作。 同步调用 同步调用执行失败，建议您自行尝试重试。 异步调用 异步调用可在界面配置最大重试次数和消息最大有限期，具体配置方法请参见配置函数异步。函数平台会根据您配置的最大重试次数和消息最大有限期（最大有限期为24小时），进行重试。重试次数和配置的最大重试次数一致，重试有效期和配置的消息最大有效期一致。

函数访问的VPC没有限制，但每个函数最多只可以配置一个VPC，同时只能访问一个VPC内的资源。

DRDS支持字段级别的加解密功能，本文为您介绍该功能的具体使用方法。 注意 本功能尚在小范围公测中，请注意评估功能可能带来的风险并谨慎使用。 前提条件 已创建库表。 目标库表为分片表，且已设置分片规则。设置分片规则的操作，请参见库表管理。 背景信息 DRDS支持字段级别的加解密，通过该功能，可以为您的库表字段进行加密，提高数据安全性。 开启字段加密后，DRDS根据用户配置的字段，将DML类型的SQL语句中对应的字段重写为加密内容后写入到底层数据中。对DQL类型的SQL，如果用户有解密权限，会根据字段解密被加密的字段内容。适用于需要对用户身份证、电话号码等敏感信息加密的场景。 使用限制 仅V5.1.20.0.4及以后版本创建的实例，支持字段加密功能。 仅支持字符串类型的字段进行加密。 开启、关闭或修改字段均对存量数据不生效，仅对新增数据生效。 只支持对表的字段进行加密。 注意事项 开启加密功能后，仅对增量数据进行加密。因此您需要自行处理数据库中原始的存量数据。 开启加密功能后，如果您执行的SQL语句含有加密字段，则存在如下限制： 注意 如果您执行的SQL语句不含有加密字段，则不影响SQL语句执行结果。 支持进行like 和等值查询，比如name是加密字段时，您可以执行如下操作： plaintext select id , name from student where student.name 'xxx'； select id , name from student where 'xxx 'student.name ； SQL语句中涉及加密的字段，只支持单表的查询，包括包含单表自身的子查询，比如 select name from (select name from student ) a ，加密字段的条件只能放到子查询语句中。 不支持join语句里含有加密字段。 不支持对加密字段进行函数计算。 不支持加密字段作为查询条件时不区分大小写功能。如果设置了不区分大小写功能，则加密后大小写对应的加密数据没有大小写对应关系，不区大小写功能将会失效。 加密字段不支持比较操作，如：大于、小于、ORDER BY、BETWEEN 等。 加密字段不支持计算操作，如：AVG、SUM 以及计算表达式。 加密字段只支持字符类型。 不支持udpate 加密字段A 字段B 语法。

本文简述时间关函数的语法、作用、入参、返回值、示例。 ctyun.now 函数信息详见下表： 项目 描述 语法 secs ctyun.now() 作用 从nginx时间缓存，返回当前时间戳。 入参 无。 返回值 secs : number，带小数表示毫秒的时间戳，例如 1657678155.998。 示例： livecodeserver local secs ctyun.now() secs 1657678155.998 ctyun.time 函数信息详见下表： 项目 描述 语法 sec ctyun.time() 作用 从nginx时间缓存，返回当前时间戳。 入参 无。 返回值 sec : number，时间戳，例如 1657678155。 示例： livecodeserver local sec ctyun.time() sec 1657678155 ctyun.localtime 函数信息详见下表： 项目 描述 语法 str ctyun.locattime() 作用 从nginx时间缓存，返回当前时间。 入参 无。 返回值 str: 返回nginx 缓存时间的本地时间（格式为 ）yyyymmdd hh:mm:ss。 示例： abnf local str ctyun.localtime() str "20220715 15:31:20" ctyun.utctime 函数信息详见下表： 项目 描述 语法 str ctyun.utctime() 作用 从nginx时间缓存，返回当前时间。 入参 无。 返回值 str: 返回nginx 缓存时间的utc时间（格式为 ）yyyymmdd hh:mm:ss。 示例： abnf local str ctyun.utctime() str "20220715 07:31:20"

操作步骤 1. 登录工作流控制台，点击目标工作流，进入工作流详情详情。 2. 在配置选项卡中，选择左边的 工作流调度 选项卡。 3. 点击 创建工作流调度 ，在弹出的右抽屉中选择 Kafka触发器，配置参数解释如下表。 配置项 操作说明 示例 触发器类型 选择Kafka触发器。 Kafka触发器 名称 填写自定义的触发器名称。 kafkatrigger Kafka实例 选择已创建的Kafka实例。 Topic 选择已创建的Kafka实例的Topic。 Group ID • 快速创建 ：推荐方案。自动创建以GROUPFCTrigger{triggername}{uuid}命名的Group ID。 • 使用已有：选择Kafka实例已有的GroupID，请您注意不要与已有的业务混用GroupID，否则会影响已有的消息收发。 消费任务并发数 消费者的并发数量，有效取值范围为[1,20]，建议不超过Topic的分区数。该值同时影响投递到函数的并发数。 消费位点 选择消息的消费位点，即触发器从kafka消息队列开始拉取消息的位置。 • 最早位点 ：从最早位点开始消费。 • 最新位点：从最新位点开始消费。 最新位点 调用方式 选择函数调用方式。 • 同步调用 ：指触发器消费topic消息后投递到函数是同步调用，会等待函数响应后继续下一个消息投递。但消费任务并发数大于1时，多个消费者有可能会并发消费消息并投递，并发的情况视topic队列本身积存的消息而定。 • 异步调用：指触发器消费topic消息后投递到函数是异步调用，不会等待函数响应，可以快速消费事件。 同步调用 触发器启用状态 创建触发器后是否立即启用。默认选择开启，即创建触发器后立即启用触发器。 启用 推送配置 • 批量推送条数 ：批量推送的最大值，积压值达到后立刻推送，取值范围为[1,10000]。 • 批量推送间隔 ：批量推送的最大时间间隔，达到后立刻推送，单位秒，取值[0,15]。默认0无需等待，数据直接推送。 • 推送格式：函数收到的事件格式，详情请查阅触发器事件消息格式。 重试策略 消息推送函数失败后重试的策略，共两种： • 指数退避 ：指数退避重试，重试5次，重试周期为2,4,8,16,32（秒）。 • 线性退避：线性退避重试，重试5次，重试周期为1,2,3,4,5（秒）。 容错策略 当重试次数耗尽后仍然失败时的处理方式： • 允许容错 ：当异常发生并超过重试策略配置时直接丢弃。 • 禁止容错：当异常发生并超过重试策略配置时继续阻塞执行。 死信队列 当容错策略为：允许容错时，可以额外开启死信队列。当开启死信队列时且异常发生并超过重试策略配置时，消息会被投递到指定的消息队列里，当前只支持投递到kafka和rocketmq

您可以通过本页了解天翼云TeleDB数据库的应用程序语法。 建立函数语法 plaintext CREATE [OR REPLACE] FUNCTION [模式名.]函数名 ([参数模式 [参数名] 数据类型 [default 默认值] [,…]]) RETRUNS [SETOF] 数据类型 AS [标签] [DECLARE 变量定义] BEGIN 注释 /注释/ 语句执行 END; [标签] LANGUAGE PLPGSQL; [OR REPLACE] 更新函数介绍 OR REPLACE 的作用为函数存在时则替换，建立 PL/pgsql 函数时如果不带 OR REPLACE 关键字， 则遇到函数已经存在，系统会报错，如下所示： plaintext teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb CREATE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; ERROR: function "f" already exists with same argument types teledb CREATE OR REPLACE FUNCTION f() RETURNS VOID AS $$ BEGIN RAISE NOTICE 'Hello ,teledb'; END; $$ LANGUAGE PLPGSQL; CREATE FUNCTION teledb select prosrc from pgproc where proname'f'; prosrc BEGIN + RAISE NOTICE 'Hello ,teledb';+ END; + (1 row) teledb select f(); NOTICE: Hello ,teledb f (1 row) [模式名.]函数名介绍 建立函数名称，模式名可以指定，也可以不指定，不指存则存放在当前模式下，如上面例子就没有指定模式名，则就存放在当前模式下，如下所示： plaintext teledb select from pgnamespace; nspname nspowner nspacl ++ pgtoast 10 pgoracle 10 squeeze 10 pgtemp1 10 pgtoasttemp1 10 pgcatalog 10 {teledbUC/teledb,U/teledb} public 10 {teledbUC/teledb,UC/teledb} informationschema 10 {teledbUC/teledb,U/teledb} (8 rows) teledb

本文介绍如何在Python运行环境下的日志打印。 打印日志 当需要查看函数运行相关的自定义状态时，可以使用如下几种方式打印日志至标准输出stdout。往标准输出stdout打印的日志内容会被函数收集。 以下分别介绍所使用的几种日志打印方法。 使用print打印日志 使用此方法打印日志会将内容原样输出到日志中。相应的执行代码及输出的日志内容如下所示。 def handler(event, context): print ('hello world') return 'done' hello world 使用logging模块打印日志 使用此方法打印的每条日志中都会包含时间、RequestId、日志级别等信息。相应的执行代码及输出的日志内容如下所示。 import logging def handler(event, context): logger logging.getLogger() logger.info('hello world') return 'done' 20241114 09:34:34.052 a8b30ba91afc46cd98b758e2a443ced0 [INFO] hello,world 查看日志 函数执行完成后，您可以在函数详情页的日志页签查看日志信息。

本文简述响应处理可以使用的相关函数的语法、作用、入参、返回值、示例。 ctyun.resp.getheaders 函数信息详见下表： 项目 描述 语法 headers, err ctyun.resp.getheaders(maxheaders?, raw?) 作用 获取响应头。 入参 maxheaders : numbe类型，缺省为100， 表示最多返回头部数量，为0表示不限制。 raw : bool类型，缺省为false，false 表示表头名称转成纯小写。 返回值 headers : table，保存全部返回的响应头，重复响应头的值为table。 err：字符串类型，错误描述，正确时为nil。 注意：建议ctyun.req.enrollheaderback 回调函数内使用。 示例： abnf local headers ctyun.resp.getheaders() headers {["server"] "openresty"} ctyun.resp.getcode 函数信息详见下表： 项目 描述 语法 respcode ctyun.resp.getcode() 作用 获响应状态码。 入参 无。 返回值 number 状态码 注意： 建议ctyun.req.enrollheaderback 回调函数内使用。 示例： abnf local respcode ctyun.resp.getcode() respcode 200 ctyun.resp.setheader 函数信息详见下表： 项目 描述 语法 ctyun.resp.setheader(headername, headervalue) 作用 设置响应头。 入参 headername：str, 响应头名。 headervalue：str, 响应头值，nil 或者空字符串表示删除。 返回值 无。 示例： stylus ctyun.resp.setheader("test", "aaaaaa") 增加响应头 test:aaaaaa