Kafka触发器可以订阅天翼云提供的分布式消息队列Kafka实例，并根据消息触发关联的函数，借此能力，使得函数可以消费指定Topic的消息，执行自定义处理逻辑。 注意事项 Kafka触发器订阅的Kafka实例必须和函数计算的函数实例在相同地域。 前提条件 已创建函数。 已开通分布式消息Kafka实例（KAFKA引擎版），详情请参考创建分布式消息服务Kafka实例。 已创建Topic，创建GroupID（可选）。 操作步骤 1. 登录函数计算控制台，点击目标函数，进入函数详情。 2. 选择详情下顶部的配置选项卡。 3. 在配置选项卡 中，选择左边的触发器选项卡。 4. 点击创建触发器 ，在弹出的右抽屉中选择Kafka触发器，配置参数解释如下。 配置项 操作 示例 触发器类型 选择Kafka触发器。 Kafka触发器 名称 填写自定义的触发器名称。 kafkatrigger 版本或别名 默认值为LATEST，支持选择任意函数版本或函数别名。 LATEST 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

构建层的ZIP包 创建层时，需要将所有内容打包成ZIP文件。层的内容会被函数计算运行时解压到/opt目录下。 构建层的ZIP包的方式与构建代码包的方式相似。为了让函数在运行时正确加载并使用层发布的库，库的代码目录结构需符合各语言的标准目录规范。具体信息可以参考各运行时的使用层说明。如果依赖库按规范打包，函数计算运行时会自动为您添加各语言的依赖库搜索路径，无需手动指定完整路径。若希望自定义层的目录结构，则需要在代码中显式指定依赖库的搜索地址。 以python为例，构建层ZIP包的具体步骤示例如下： 说明 1. 在本地构建层时，使用的编程语言版本需要和在函数计算选择的运行时的编程语言版本保持一致。 2. 下面创建的工作目录examplelayercode仅为示例，您在实际操作过程中可以按需替换目录名称。 1. 执行以下命令创建工作目录。 shell mkdir examplelayercode 2. 进入已创建的工作目录。 shell cd examplelayercode 3. 执行以下命令安装依赖库到 examplelayercode/python。 shell pip3 install target ./ ${PackageName} ${PackageName}是您要安装的依赖包的名称，例如boto3。 代码示例如下： shell pip3 install target ./ boto3 安装完成后，目录结构如下： plain examplelayercode/ ├── bin ├── boto3 ├── boto31.35.66.distinfo ├── botocore ├── botocore1.35.66.distinfo ├── dateutil ├── jmespath ├── jmespath1.0.1.distinfo ├── pycache ├── pythondateutil2.9.0.post0.distinfo ├── s3transfer ├── s3transfer0.10.4.distinfo ├── six1.16.0.distinfo ├── six.py ├── urllib3 └── urllib31.26.20.distinfo 在examplelayercode目录，执行以下命令打包依赖。 shell zip r mylayercode.zip .

RocketMQ触发器可以订阅分布式消息服务RocketMQ并根据消息触发关联的函数，借此能力，使得函数可以消费指定topic的消息，执行自定义处理逻辑。 注意事项 RocketMQ触发器订阅的分布式消息服务RocketMQ实例必须和函数计算的函数实例在相同地域。 前提条件 创建函数。 开通分布式消息服务RocketMQ实例（RocketMQ引擎类型），详情请参考开通RocketMQ实例。 创建Topic和GroupID。 创建用户，且默认Topic权限设置为：PUBSUB，默认消费组权限为SUB。详情请参考创建用户。 操作步骤 1. 登录函数计算控制台，点击目标函数，进入函数详情。 2. 选择详情下顶部的配置选项卡。 3. 在配置 选项卡中，选择左边的触发器选项卡。 4. 点击创建触发器 ，在弹出的右抽屉中选择RocketMQ触发器，配置参数解释如下。 配置项 操作 示例 触发器类型 选择RocketMQ触发器。 RocketMQ触发器 名称 填写自定义的触发器名称。 rocketmqtrigger 版本或别名 默认值为LATEST，支持选择任意函数版本或函数别名。 LATEST RocketMQ 实例 选择已创建的RocketMQ实例。 Topic 选择已创建的RocketMQ实例的Topic。 Group ID 选择已创建的RocketMQ实例的Group ID。 消费位点 选择消息的消费位点，即触发器从RocketMQ实例开始拉取消息的位置。取值说明如下。 最新位点 ：从最新位点开始消费。 最早位点 ：从最早位点开始消费。 指定时间戳：从指定时间戳开始消费。 最新位点 调用方式 选择函数调用方式。 同步调用 ：指触发器消费topic消息后投递到函数是同步调用，会等待函数响应后继续下一个消息投递。 异步调用：指触发器消费topic消息后投递到函数是异步调用，不会等待函数响应，可以快速消费事件。 同步调用 用户ID RocketMQ实例用户ID，需要在RocketMQ控制台创建。 密钥 RocketMQ实例用户密钥，需要在RocketMQ控制台创建。 触发器启用状态 创建触发器后是否立即启用。默认选择开启，即创建触发器后立即启用触发器。 推送配置 批量推送条数：批量推送的最大值，积压值达到后立刻推送，取值范围为 [1, 10000]。 批量推送间隔：批量推送的最大时间间隔，达到后立刻推送，单位秒，取值[0,15]。默认0无需等待，数据直接推送。 推送格式：函数收到的事件格式，详情请查阅触发器事件消息格式。 重试策略 消息推送函数失败后重试的策略，共两种： 指数退避：指数退避重试，重试5次，重试周期为2，4，8，16，32（秒）。 线性退避：线性退避重试，重试5次，重试周期为1，2，3，4，5（秒）。 容错策略 当重试次数耗尽后仍然失败时的处理方式： 允许容错：当异常发生并超过重试策略配置时直接丢弃。 禁止容错：当异常发生并超过重试策略配置时继续阻塞执行。 死信队列 当容错策略为：允许容错时，可以额外开启死信队列。当开启死信队列时且异常发生并超过重试策略配置时，消息会被投递到指定的消息队列里，当前只支持投递到kafka和rocketmq

version命令管理部署在函数计算的函数的版本。 version publish 命令 发布函数版本。 参数解析 参数全称 参数缩写 Yaml 模式下必填 Cli 模式下必填 参数含义 region 选填 必填 资源池ID，请参考资源池列表 functionname 选填 必填 函数名称 description 选填 选填 版本描述 操作案例 Yaml 模式 进入到资源描述文件（s.yaml）所在的路径，然后执行如下命令发布函数版本： shell s version publish description "test version" Cli 模式 直接执行如下命令发布函数版本： shell s cli faascf version publish region bb9fdb42056f11eda1610242ac110002 functionname helloworld description "test version" 执行完成输出示例： plaintext createTime: 1748490043 description: test version id: 39160107585620536 versionId: 1 version list 命令 查看已发布的函数版本。 参数解析 参数全称 参数缩写 Yaml 模式下必填 Cli 模式下必填 参数含义 region 选填 必填 资源池ID，请参考资源池列表 functionname 选填 必填 函数名称 操作案例 Yaml 模式 进入到资源描述文件（s.yaml）所在的路径，然后执行如下命令查看函数版本： shell s version list Cli 模式 直接执行如下命令查看函数版本： shell s cli faascf version list region bb9fdb42056f11eda1610242ac110002 functionname helloworld 执行完成输出示例： plaintext description: test version versionId: 1 createTime: 20250529T11:40:43.029597+08:00 updateTime: 20250529T11:40:43.029597+08:00 version remove 命令 删除函数版本。

参数 说明 触发器类型 用于触发函数计算的入口，目前支持HTTP触发器：使用您的全站加速域名作为入口供客户端访问。 作用域名 当您创建HTTP触发器时，需要关联您名下的全站加速域名。 HTTP路由 函数根据具体路由规则生效，支持通配符配置，例如：/h5/abc 旁路触发 旁路触发生效后，符合规则的客户端请求将被发送到边缘函数执行，随后继续执行全站加速域名配置并回源，适合于一些鉴权校验或日志打点的场景。旁路触发关闭时，符合规则的客户端请求将被发送到边缘函数，执行个性化处理。

函数规格 标准资费 单位 10ms 1 元/百万次 50ms 3 元/百万次 100ms 5 元/百万次

alias命令管理部署在函数计算的函数的别名。 alias publish 命令 发布函数别名。 参数解析 参数全称 参数缩写 Yaml 模式下必填 Cli 模式下必填 参数含义 region 选填 必填 资源池ID，请参考资源池列表 functionname 选填 必填 函数名称 aliasname 必填 必填 别名 versionid 必填 必填 版本ID description 选填 选填 别名描述 gray 选填 选填 灰度配置 操作案例 Yaml 模式 进入到资源描述文件（s.yaml）所在的路径，然后执行如下命令发布函数别名： shell s alias publish aliasname testalias versionid 5 description "test alias" Cli 模式 直接执行如下命令发布函数别名： shell s cli faascf alias publish region bb9fdb42056f11eda1610242ac110002 functionname helloworld aliasname testalias versionid 5 description "test alias" 执行完成输出示例： plaintext aliasName: testalias versionId: 5 grayVersionId: description: test alias grayType: 0 aliasGrayConfig: createTime: 20250529T16:39:04.674226793+08:00 updateTime: 20250529T16:39:04.674226793+08:00 alias get 命令 查看已发布的函数别名。 参数解析 参数全称 参数缩写 Yaml 模式下必填 Cli 模式下必填 参数含义 region 选填 必填 资源池ID，请参考资源池列表 functionname 选填 必填 函数名称 aliasname 必填 必填 别名

本文介绍C如何实现并应用函数实例生命周期回调方法。 使用说明 当您实现并配置函数实例生命周期回调后，函数计算将在相关实例生命周期事件发生时调用对应的回调程序。函数实例生命周期涉及Initializer和PreStop回调。 Initializer回调 Initializer回调在函数实例启动成功后，请求处理程序（Handler）之前执行。 PreStop回调 PreStop回调在函数实例销毁前执行。 Initializer回调和PreStop回调的方法签名一样，入参只有一个context参数，提供在调用时的运行上下文信息。回调方法定义如下： csharp using System; using System.IO; using System.Text; using System.Text.Json; using System.Threading.Tasks; using Microsoft.Extensions.Logging; using Serverless.Cf; namespace Example { public class Hello { public void PreStop(ICfContext context) { context.Logger.LogInformation("hello prestop"); } public void Init(ICfContext context) { context.Logger.LogInformation("hello init"); } public async Task Handler(Stream input, ICfContext context) { var str "Hello world"; byte[] bytetxt Encoding.UTF8.GetBytes(str); MemoryStream output new MemoryStream(); await input.CopyToAsync(output); output.Write(bytetxt, 0, bytetxt.Length); return output; } static void Main(string[] args) { } } }

定时触发器能够依照您预设的确切时刻或周期性指令，自动启动函数的运行，这为您提供了一种灵活的方式来安排任务的执行，特别适合那些需要按计划重复执行任务的场景。 使用场景 定时触发器非常灵活，适用于各种时间相关的场景，例如： 周期性任务，例如每周五发送运维报表。 定时任务，例如设定在指定日期时间开启游戏活动。 前提条件 创建函数 操作步骤 1. 登录函数计算控制台，点击目标函数，进入函数详情。 2. 选择详情下顶部的配置选项卡。 3. 在配置 选项卡中，选择左边的触发器选项卡。 4. 点击创建触发器 ，在弹出的右抽屉中选择定时触发器，配置参数解释如下表。 参数 操作 示例 触发器类型 选择定时触发器。 定时触发器 名称 填写自定义的触发器名称。 MyTrigger 版本或别名 默认值为LATEST，支持选择任意函数版本或函数别名。 LATEST 触发方式 根据需要选择触发方式： 时间间隔 ：触发器每隔n分钟触发一次函数执行。 指定时间 ：选择时区，并指定日期、星期和时间，触发器在某时区的指定时间触发一次函数执行。 自定义：支持秒级配置，使用6段式Cron表达式，兼容Quartz的表达式。 /5 触发消息 支持发送自定义消息。该消息内容将会作为触发函数的Event结构体的data字段。 hello, trigger

函数表达式 函数描述 Addition operator Assign a value (as part of a SET statement, or as part of the SET clause in an UPDATE statement) & Bitwise AND ~ Bitwise inversion ^ Bitwise XOR BINARY Cast a string to a binary string Change the sign of the argument NOT Check whether a value is not within a range of values BETWEEN … Check whether a value is not within a range of values AND … Check whether a value is not within a range of values BETWEEN … AND … Check whether a value is within a range of value STRCMP Compare two strings / Division operator Equal operator > Greater than operator > Greater than or equal operator DIV Integer division << Left shift < Less than operator < Less than or equal operator AND, && Logical AND OR Logical OR XOR Logical XOR Minus operator %, MODModulo operator Multiplication operator NOT, ! Negates value NOT REGEXP Negation of REGEXP NOT LIKE Negation of simple pattern matching !, <> Not equal operator IS NOT NULL NOT NULL value test IS NULL NULL value test <> NULLsafe equal to perator REGEXP Pattern matching using regular expressions Coalesce Return the fifirst nonNULL argument GREATEST Return the largest argument LEAST Return the smallest argument >> Right shift LIKE Simple pattern matching RLIKE Synonym for REGEXP IS NOT Test a value against a boolean IS Test a value against a boolean

MQTT触发器可以订阅分布式消息服务MQTT并根据消息触发关联的函数，借此能力，使得函数可以消费指定Topic的消息，执行自定义处理逻辑。 前提条件 已创建函数。 已创建MQTT实例 操作步骤 1. 登录函数计算控制台，点击目标函数，进入函数详情。 2. 选择详情下顶部的配置选项卡。 3. 在配置选项卡中，选择左边的触发器选项卡。 4. 点击创建触发器 ，在弹出的右抽屉中选择MQTT触发器，配置参数解释如下: 配置项 操作 示例 触发器类型 选择MQTT触发器。 MQTT触发器 名称 填写自定义的触发器名称。 mqtttrigger 版本或别名 默认值为LATEST，支持选择任意函数版本或函数别名。 LATEST MQTT实例 选择已创建的MQTT实例。 Topic 填写订阅的消息Topic，请确保topic的命名符合以下"^[azAZ09/ +]+$"正则表达式 mytopic 调用方法 选择函数调用方式。 同步调用 ：指触发器消费消息后投递到函数是同步调用，会等待函数响应后继续下一个消息投递。 异步调用：指触发器消费消息后投递到函数是异步调用，不会等待函数响应，可以快速消费事件。 用户ID 终端设备连接MQTT队列需要先创建用户密码，详情请查看认证授权 密钥 终端设备连接MQTT队列需要先创建用户密码，详情请查看认证授权 触发器启用状态 创建触发器后是否立即启用。默认选择开启，即创建触发器后立即启用触发器。 启用 注意 需要对用户名进行主题授权，MQTT触发器才能正常工作

概述 本章节主要介绍如何将智能体快速集成到其他业务系统中。 前提条件 已创建可用的智能体，并为智能体创建Endpoint 已开通函数计算服务 在函数计算控制台“域名管理”配置域名 操作步骤 进入集成与发布页面 1. 登录智能体引擎控制台，在左侧导航栏，单击智能体，进入智能体列表页面。 2. 在智能体列表页面中，点击对应的智能体，进入智能体详情页面。 3. 选择详情页顶部的集成与发布 选项卡，选择UI集成 或代码集成。 UI集成 智能体引擎服务为您提供全屏嵌入 、抽屉式 、浮窗式等3种前端模版，支持一键部署为前后端一体的智能体应用。 以下是部署生成的操作示例： 1. 选择集成样式，如：全屏嵌入。 2. 点击部署生成 按钮，在集成配置页面选择访问前端页面的自定义域名 的子域名前缀和根域名，以及智能体的Endpoint ，然后点击确定按钮。 注意 平台会根据输入的自定义域名前缀和根域名去创建一个子域名，路由指向部署的UI集成函数。为了能顺利访问UI集成函数，请确保： 1. 子域名已配置CNAME。未配置CNAME的域名将无法访问到UI集成函数，CNAME配置请参考 < 2. 域名已备案。未备案的域名，浏览器访问页面时默认以附件下载模式打开 3. 等待部署完成，在部署资源列表，您将看到已部署的前端项目对应的函数和访问地址。 4. 点击访问地址，进入部署生成的智能体服务UI界面。 5. 在部署资源列表 ，您也可以点击删除服务进行删除不再需要的集成服务，对应的函数和访问域名将会被删除。

本文介绍如何在天翼云函数计算控制台创建、查看、编辑和删除应用环境。 创建环境 在函数计算控制台，点击对应的应用进入应用详情页面，您可以点击创建环境按钮，进入环境创建页面。 填写字段说明： 环境名称：一个应用不能出现两个相同的环境名称。 环境类型 ：根据实际的业务诉求选择合适的环境类型，支持测试环境 、预发环境 、生产环境三种环境类型。 描述：环境的描述。 流水线配置 ：环境对应的流水线配置，请见管理流水线。 查看环境 在函数计算控制台，点击对应的应用进入应用详情页面，可以看到当前应用关联的环境列表。 点击对应的环境名称，进入环境详情页面，该页面包含环境详情、流水线管理等2个页签。 环境详情 环境详情页签主要包含应用和环境的基本信息、环境绑定的代码源、部署构建历史以及部署的资源。 流水线管理 您可以在此处配置当前环境的构建流水线，请见管理流水线。 编辑环境 您可以在环境详情页面环境详情页签处，点击环境信息旁的编辑链接，进行编辑环境的描述、分支绑定以及流水线触发方式。 删除环境 您可以在应用详情页，点击对应环境操作列的删除链接，然后您需要确认选择需要删除环境相关的资源，进行删除指定环境。

函数库 函数名 全局 assert、error、ipairs、next、pairs、pcall、select、tonumber、tostring、type、unpack、xpcall。 math abs、acos、asin、atan、atan2、ceil、cos、cosh、deg、exp、fmod、floor、frexp、huge、ldexp、log、log10、max、min、modf、pi、pow、rad、random、 sin、sinh、sqrt、tan、tanh。 os clock、difftime、time。 string byte、char、find、format、gmatch、gsub、len、lower、match、reverse、sub、upper。 table insert、maxn、remove、sort。 bit arshift、band、bnot、bor、bswap、bxor、lshift、rol、ror、rsh。

HTTP触发器 HTTP触发器 Http触发器为函数提供了基于Http协议的访问方式，主要适用于web服务、API暴露等场景，同时也提供了丰富的配置已满足各种访问形式。 使用限制 根据相关规章制度，Http触发器的域名需要您提供，需要提前创建自定义域名，详情请查看配置自定义域名。 函数计算会基于您提供的自定义域名创建子域名作为工作流访问端点url，因此也需要您给子域名配置CNAME记录。 一个工作流下，只能创建一个Http触发器。 触发消息格式 通过HTTP触发器和自定义域名访问工作流时，仅会把请求中的body部分作为工作流的输入，数据类型必须为JSON格式。 操作步骤 1. 登录工作流控制台，点击目标工作流，进入工作流详情详情。 2. 在配置选项卡中，选择左边的 工作流调度 选项卡。 3. 点击 创建工作流调度 ，在弹出的右抽屉中选择 Http触发器，配置参数解释如下表。 配置项 参数说明 示例 名称 工作流调度的名称 httpTicker 请求方法 触发器支持的Http请求方法，目前只支持POST。 POST 公网 选择已创建的自定义域名，并确保该域名已经配置CNAME记录，记录值每个地域的内外网不同，具体留意页面提示。适用于公网环境访问。 认证方式 无需认证：请求没有认证限制，任何人都能访问。 JWT认证：请求启用JWT认证，访问时需要带上jwt，函数网关会自动校验请求的合法性。配置方式请参考函数计算HTTP触发器> JWT配置指南 部分

签名过程 下图说明了签名计算过程。 下表描述了图中显示的功能。用户需要为这些功能实现代码。 功能 描述 :: Lowercase() 将字符串转换为小写。 Hex() 小写十六进制编码。 SHA256Hash() 安全散列算法（SHA）加密散列函数。 HMACSHA256() 使用提供的签名密钥的SHA256算法计算HMAC。这是最终的签名。 Trim() 删除任何前导或尾随空格。 UriEncode() URI编码每个字节。UriEncode（）必须强制执行以下规则： URI编码除了下面字符之外的每个字节：'A' 'Z'，'a' 'z'，'0' '9'，' '，'.'，''和'〜'。 空格字符是保留字符，必须编码为“％20”（而不是“+”）。 每个URI编码字节由'％'和两位十六进制值组成。 十六进制值中的字母必须为大写，例如“％1A”。 除了文件名之外，对正斜杠字符'/'进行编码。例如，如果文件名称为photos/Jan/sample.jpg，则不对键名称中的正斜杠进行编码。 说明 建议您编写自己的自定义UriEncode函数，以确保您的编码可以正常工作。 以下是Java中的示例UriEncode（）函数。 public static String UriEncode(CharSequence input, boolean encodeSlash) { StringBuilder result new StringBuilder(); for (int i 0; i 'A' && ch 'a' && ch '0' && ch < '9') ch '' ch '' ch '~' ch '.') { result.append(ch); } else if (ch '/') { result.append(encodeSlash ? "%2F" : ch); } else { result.append(toHexUTF8(ch)); } } return result.toString(); } 使用参数的签名过程与使用请求头的签名过程类似，如下所示： 由于创建预签名URL的时候，并不知道有效负载的内容，所以设置常量UNSIGNEDPAYLOAD。 规范查询字符串（Canonical Query String）必须包括除了XAmzSignature之外的所有上述查询字符串。 规范标头必须包括HTTP Host标头。如果用户想包含xamz请求头，这些标头都将参与签名计算。用户可以选择其他的请求头是否参与签名计算。安全起见，尽可能多的请求头参与签名计算。

函数计算 当事件目标选择函数计算时，事件目标的type值为faas，eventTargets中的resourceKey字段中含义如下表所示。 resourceKey 是否必传 form value template functionName 是 CONSTANT 函数名。 无 functionVersion 否，当不传functionAlias时此参数必传 CONSTANT 函数版本。 无 functionAlias 否，当不传functionVersion时此参数必传 CONSTANT 函数别名。 无 invokeType 是 CONSTANT 调用方式。 同步：synchronous 异步：asynchronous 无 value 否 ORIGINAL CONSTANT JSONPATH TEMPLATE 函数的消息体内容。不传时默认为全部事件。 如果form选择TEMPLATE，则在此处配置模板。详见事件内容转换。 请求示例： plaintext { "eventBusName": "test", "eventRuleName": "test", "desc": "", "filterPattern": "{}", "eventTargets": [ { "type": "faas", "eventTargetName": "cdBFQM0yVUw2FSaJ7EPcG", "params": [ { "resourceKey": "functionName", "value": "testgo4", "form": "CONSTANT" }, { "resourceKey": "functionVersion", "value": "LATEST", "form": "CONSTANT" }, { "resourceKey": "invokeType", "value": "synchronous", "form": "CONSTANT" }, { "resourceKey": "value", "value": "", "form": "ORIGINAL" } ] } ] } 云工作流 当事件目标选择云工作流时，事件目标的type值为cloudflow，eventTargets中的resourceKey字段中含义如下表所示。 resourceKey 是否必传 form value template workflowName 是 CONSTANT 工作流流程名。 无 executionName 是 CONSTANT JSONPATH TEMPLATE EMPTY 工作流执行名称。 如果form选择TEMPLATE，则在此处配置模板。详见事件内容转换。 invokeType 是 CONSTANT 调用方式。 同步：synchronous 异步：asynchronous 无 executionInput 是 CONSTANT JSONPATH TEMPLATE EMPTY ORIGINAL 云工作流输入Body。 如果form选择TEMPLATE，则在此处配置模板。详见事件内容转换。 请求示例： plaintext { "eventBusName": "test", "eventRuleName": "test", "desc": "", "filterPattern": "{}", "eventTargets": [ { "type": "cloudflow", "eventTargetName": "9AzCNjDn7aS9YKbdFAQj", "params": [ { "resourceKey": "workflowName", "value": "test1", "form": "CONSTANT" }, { "resourceKey": "invokeType", "value": "synchronous", "form": "CONSTANT" }, { "resourceKey": "executionName", "value": "", "form": "EMPTY" }, { "resourceKey": "executionInput", "value": "", "form": "EMPTY" } ] } ] }

使用说明 当您实现并配置函数实例生命周期回调后，函数计算将在相关实例生命周期事件发生时调用对应的回调程序。函数实例生命周期涉及Initializer和PreStop回调。 Initializer回调 Initializer回调在函数实例启动成功后，请求处理程序（Handler）之前执行。 PreStop回调 PreStop回调在函数实例销毁前执行。 Path 输入请求 期望的响应 （可选）POST /initialize 请求体：无。 响应体：函数 Initializer的返回值。StatusCode2xx：成功状态。非2xx：失败状态。 （可选）GET /prestop 请求体：无。 响应体：函数PreStop的返回值。StatusCode2xx：成功状态。非2xx：失败状态。 如下是一个PYthon 3.10的自定义函数简单实现了Initializer回调和PreStop回调的例子： python from http.server import BaseHTTPRequestHandler, HTTPServerclass HelloWorldHandler(BaseHTTPRequestHandler): def writeresponse(self, status, bodyNone): self.sendresponse(status) self.sendheader('Contenttype', 'text/plain') self.endheaders() if body is not None: self.wfile.write(body.encode()) def doGET(self): if self.path "/prestop": self.writeresponse(200) else: self.writeresponse(200, "invoke success") def doPOST(self): if self.path "/initialize": self.writeresponse(200) else: self.writeresponse(200, "invoke success")def run(serverclassHTTPServer, handlerclassHelloWorldHandler, port9000): serveraddress ('', port) httpd serverclass(serveraddress, handlerclass) print(f'Starting httpd on port {port}...') httpd.serveforever()if name 'main': run()

本文介绍如何在Java运行环境下打印和查看函数日志。 打印日志 fcruntimecore库提供的 context.getLogger方法打印日志。该方法打印的每条日志中都包含时间、RequestId和日志级别等信息。示例代码如下所示： package example; import com.ctg.faas.runtime.Context; import com.ctg.faas.runtime.PojoRequestHandler; public class App implements PojoRequestHandler { @Override public String handleRequest(String input, Context context) { context.getLogger().info("Hello log"); return input; } } 目前函数计算提供的Logger支持打印TRACE、DEBUG、INFO、WARN、ERROR、FATAL级别的日志信息。 查看日志 函数执行完成后，您可以在函数详情页的日志页签查看日志信息。 例如，执行上面的示例代码会看到如下日志输出： 20240312 12:09:50.935 [XNIO1 task1] INFO fcLog [xxxx] Hello log

批量数据迁移集群 批量数据迁移给用户提供的最小资源单位，一个批量数据迁移集群运行在一个弹性云主机之上，用户可以在集群中创建数据迁移作业，在云上和云下的同构/异构数据源之间批量迁移数据。 数据连接 定义访问数据实体存储（计算）空间所需的信息的集合，包括连接类型、名称和登录信息等。 作业（数据开发） 在数据开发中，作业由一个或多个节点组成，共同执行以完成对数据的一系列操作。 节点 节点用于定义对数据执行的操作。例如，使用“MRS Spark”节点可以实现在MRS中执行预先定义的Spark作业。 资源 用户可以上传自定义的代码或文本文件作为资源，并在节点运行时调用。 函数 函数可以作为脚本/作业参数的值，所有函数都以“$”符号开头，后面接函数名和参数序列。 表达式 数据开发作业中的节点参数可以使用表达式语言（Expression Language，简称EL），根据运行环境动态生成参数值。数据开发 EL表达式使用简单的算术和逻辑计算，引用内嵌对象，包括作业对象和一些工具类对象。 环境变量 环境变量是在操作系统中一个具有特定名字的对象，它包含了一个或者多个应用程序所将使用到的信息。 补数据 手工触发周期方式调度的作业任务，生成过去某时间段内的实例。

函数库 函数名 全局 assert、error、ipairs、next、pairs、pcall、select、tonumber、tostring、type、unpack、xpcall。 math abs、acos、asin、atan、atan2、ceil、cos、cosh、deg、exp、fmod、floor、frexp、huge、ldexp、log、log10、max、min、modf、pi、pow、rad、random、 sin、sinh、sqrt、tan、tanh。 os clock、difftime、time。 string byte、char、find、format、gmatch、gsub、len、lower、match、reverse、sub、upper。 table insert、maxn、remove、sort。 bit arshift、band、bnot、bor、bswap、bxor、lshift、rol、ror、rsh。

图解：DeepSeek与公有云深度融合 从基础设施到智能中枢：DeepSeek如何重塑公有云服务价值链 高性能GPU云主机助力DeepSeek深度应用 实践指南：DeepSeek驱动高效能云生态 GPU云主机/弹性云主机：零基础搭建DeepSeek云端环境指南 GPU物理机：物理机搭建DeepSeek指南 智算容器：云容器引擎与DeepSeek融合实践 函数计算：天翼云函数计算与DeepSeek大模型 Q&A：典型问题解析与策略应对 常见问题解答

场景说明 云原生容器引擎、FaaS函数计算引擎、智算平台根据波峰波谷按需启动ECI实例来满足用户降本增效提速的需求。 能够实现 多种计算引擎统一调度：提供 Pod级别的运行底座支撑不同计算引擎调度。 快速弹性扩缩 ：满足用户流量波峰波谷的资源快速扩缩。

本文介绍Java如何实现并应用函数实例生命周期回调方法。 使用说明 当您实现并配置函数实例生命周期回调后，函数计算将在相关实例生命周期事件发生时调用对应的回调程序。函数实例生命周期涉及Initializer和PreStop回调。 Initializer回调 Initializer回调在函数实例启动成功后，请求处理程序（Handler）之前执行。使用Initializer回调需要继承com.ctg.faas.runtime.FunctionInitializer接口，并实现该接口的initialize方法。 PreStop回调 PreStop回调在函数实例销毁前执行。使用PreStop回调需要继承com.ctg.faas.runtime.PreStopHandler接口，并实现该接口的preStop方法。 Initializer回调和PreStop回调的方法签名一样，入参只有一个context参数，提供在调用时的运行上下文信息。一个包含回调方法的示例如下： package example; import com.ctg.faas.runtime.Context; import com.ctg.faas.runtime.FunctionInitializer; import com.ctg.faas.runtime.PojoRequestHandler; import com.ctg.faas.runtime.PreStopHandler; public class PojoHandler implements PojoRequestHandler , FunctionInitializer, PreStopHandler { @Override public String handleRequest(String input, Context context) { context.getLogger().info("Hello:" + input); return input; } @Override public void initialize(Context context) { context.getLogger().info("initialize..."); } @Override public void preStop(Context context) { context.getLogger().info("preStop..."); } }

本文介绍DRDS支持的时间函数。 函数表达式 函数描述 ADDDATE() Add time values (intervals) to a date value ADDTIME() Add time CURDATE() Return the current date CURRENTDATE() CURRENTDATE Synonyms for CURDATE() CURRENTTIME() CURRENTTIME Synonyms for CURTIME() CURRENTTIMESTAMP() CURRENTTIMESTAMP Synonyms for NOW() CURTIME() Return the current time DATEADD() Add time values (intervals) to a date value DATEFORMAT() Format date as specified DATESUB() Subtract a time value (interval) from a date DATE() Extract the date part of a date or datetime expression DATEDIFF() Subtract two dates DAY() Synonym for DAYOFMONTH() DAYNAME() Return the name of the weekday DAYOFMONTH() Return the day of the month (031) DAYOFWEEK() Return the weekday index of the argument DAYOFYEAR() Return the day of the year (1366) EXTRACT() Extract part of a date FROMDAYS() Convert a day number to a date FROMUNIXTIME() Format UNIX timestamp as a date GETFORMAT() Return a date format string HOUR() Extract the hour LASTDAY() Return the last day of the month for the argument LOCALTIME() LOCALTIME Synonym for NOW() LOCALTIMESTAMP, LOCALTIMESTAMP() Synonym for NOW() MAKEDATE() Create a date from the year and day of year MAKETIME() Create time from hour, minute, second MICROSECOND() Return the microseconds from argument MINUTE() Return the minute from the argument MONTH() Return the month from the date passed MONTHNAME() Return the name of the month NOW() Return the current date and time PERIODADD() Add a period to a yearmonth PERIODDIFF() Return the number of months between periods QUARTER() Return the quarter from a date argument SECTOTIME() Converts seconds to ‘HH:MM:SS’ format SECOND() Return the second (059) STRTODATE() Convert a string to a date SUBDATE() Synonym for DATESUB() when invoked with three arguments SUBTIME() Subtract times SYSDATE() Return the time at which the function executes TIME() Extract the time portion of the expression passed TIMEFORMAT() Format as time TIMETOSEC() Return the argument converted to seconds TIMEDIFF() Subtract time TIMESTAMP( With a single argument, this function returns the date or datetime expression; with two arguments, the sum of the arguments TIMESTAMPADD() Add an interval to a datetime expression TIMESTAMPDIFF() Subtract an interval from a datetime expression UNIXTIMESTAMP() Return a UNIX timestamp UTCDATE() Return the current UTC date UTCTIME() Return the current UTC time UTCTIMESTAMP() Return the current UTC date and time WEEKDAY() Return the weekday index WEEKOFYEAR() Return the calendar week of the date (153) YEAR() Return the year

本文介绍如何使用C 请求处理程序响应接收到的事件并执行相应的业务逻辑。 请求处理程序 请求处理程序是一个执行的入口方法，当您的函数被调用时，函数计算会运行该方法处理请求。 您可以通过函数计算控制台页面配置请求处理程序 ，对于C 语言的函数，请求处理程序需配置为 [程序集名称]::[命名空间].[类名]::[方法名]。例如，您的程序集名称为HelloApp，命名空间为Example，方法名为Hello，方法名为Handler，则请求处理程序可配置为 HelloApp::Example.Hello::Handler。 如下是一个请求处理程序的方法实现示例： csharp using System; using System.IO; using System.Text; using System.Text.Json; using System.Threading.Tasks; using Microsoft.Extensions.Logging; using Serverless.Cf; namespace Example { public class Hello { public async Task Handler(Stream input, ICfContext context) { } static void Main(string[] args) { } } } 请求处理程序支持以下方法签名： csharp // 包含ICfContext的同步方法 OutType Handler(InType input, ICfContext context); // 不包含ICfContext的同步方法 OutType Handler(InType input); // 包含ICfContext的异步方法 Async Task Handler(InType input, ICfContext context); // 不包含ICfContext的异步方法 Async Task Handler(InType input); 方法签名说明： 方法名称：方法名称可自定义。 返回值：void、System.IO.Stream或可以被JSON序列化和反序列化的对象。 方法入参：第一个入参是 System.IO.Stream或可以被JSON序列化和反序列化的对象；第二个入参可选，当存在第二个入参时，必须是 ICfContext类型。 如果您使用到ICfContext接口，需要在代码目录下的csproj文件引入Serverless.Cf依赖： xml

图解：DeepSeek与公有云深度融合 从基础设施到智能中枢：DeepSeek如何重塑公有云服务价值链 高性能GPU云主机助力DeepSeek深度应用 实践指南：DeepSeek驱动高效能云生态 GPU云主机/弹性云主机：零基础搭建DeepSeek云端环境指南 GPU物理机：物理机搭建DeepSeek指南 智算容器：云容器引擎与DeepSeek融合实践 函数计算：天翼云函数计算与DeepSeek大模型 Q&A：典型问题解析与策略应对 常见问题解答

本文介绍Go如何实现并应用函数实例生命周期回调方法。 使用说明 当您实现并配置函数实例生命周期回调后，函数计算将在相关实例生命周期事件发生时调用对应的回调程序。 Initializer回调 Initializer回调在函数实例启动成功后，请求处理程序（Handler）之前执行。 PreStop回调 PreStop回调在函数实例销毁前执行。使用PreStop回调需要继承com.ctg.faas.runtime.PreStopHandler接口，并实现该接口的preStop方法。 Initializer回调和PreStop回调的方法签名一样，入参只有一个context参数，提供在调用时的运行上下文信息。cfruntimegosdk官方库提供了RegisterInitializerFunction、RegisterPreStopFunction方法分别用于注册Initializer回调和PreStop回调。 示例代码如下： package main import ( "context" "gitee.com/ctyunfaas/cfruntimegosdk/cf" "gitee.com/ctyunfaas/cfruntimegosdk/fccontext" ) func initialize(ctx context.Context) { fctx, : fccontext.FromContext(ctx) fctx.GetLogger().Info("initialize...") } func preStop(ctx context.Context) { fctx, : fccontext.FromContext(ctx) fctx.GetLogger().Info("preStop...") } func HandleRequest(ctx context.Context) (string, error) { fctx, : fccontext.FromContext(ctx) fctx.GetLogger().Info("HandleRequest...") return "hello world", nil } func main() { cf.RegisterPreStopFunction(preStop) cf.RegisterInitializerFunction(initialize) cf.Start(HandleRequest) }

本文介绍如何通过云工作流调用函数，使用FFmpeg工具并行对视频进行转码。 使用场景 由于视频大小限制，或有转换效率需求时，通过分片并行执行对视频转码。 准备工作 已开通函数计算。 已创建开通ZOS（对象存储）bucket。 已创建通用文件系统。 操作步骤 1. 进入函数计算控制台，在左侧导航点击应用 ，然后单击创建应用按钮。 2. 在文件处理分类中，找到视频转码云工作流 ，点击立即创建。 3. 依照提示填入网络参数、ZOS和Nas参数。 4. 点击创建应用，随后函数资源和工作流资源将根据应用名创建完成。 5. 上传视频至ZOS Bucket中。 6. 进入云工作流控制台，新工作流应当已经创建完成，工作流名与应用名一致。 7. 点击进入新创建的工作流，点击启动执行，参考以下参数填入执行输入，等待执行完成。 php { "dstformats": [ "avi" ], "ossbucketname": "workflowbucket", "outputprefix": "workflow/video/output", "segmenttimeseconds": 2, "videokey": "workflow/video/demo.mp4" } 8. 工作流成功执行后，转码后的文件将存储在对象存储outputprefix路径下。 更多控制台操作与执行结果分析请参照控制台操作文档。

图解：DeepSeek与公有云深度融合 从基础设施到智能中枢：DeepSeek如何重塑公有云服务价值链 高性能GPU云主机助力DeepSeek深度应用 天翼云SDWAN与DeepSeek超强联动，开启云上高效互联新时代 实践指南：DeepSeek驱动高效能云生态 GPU云主机/弹性云主机：零基础搭建DeepSeek云端环境指南 GPU物理机：物理机搭建DeepSeek指南 智算容器：云容器引擎与DeepSeek融合实践 函数计算：天翼云函数计算与DeepSeek大模型 Q&A：典型问题解析与策略应对 常见问题解答

invoke命令调用部署在函数计算的函数。 参数解析 参数全称 参数缩写 Yaml 模式下必填 Cli 模式下必填 参数含义 region 选填 必填 资源池ID，请参考资源池列表 functionname 选填 必填 函数名称 timeout 选填 选填 客户端调用超时时间，默认为：1800，单位为：秒 event e 选填 选填 事件 waitfunctionready 选填 选填 等待函数就绪再调用，默认值：false，最大等待时间为120秒，等待间隔为10秒 操作案例 Yaml 模式 进入到资源描述文件（s.yaml）所在的路径，然后执行如下命令调用函数： shell s invoke Cli 模式 直接执行如下命令调用函数： shell s cli faascf invoke region bb9fdb42056f11eda1610242ac110002 functionname helloworld 执行完成输出示例： plaintext status: 200 headers: contentlength: 11 contenttype: text/plain; charsetutf8 date: Tue, 27 May 2025 08:06:01 GMT xfcrequestid: cfece19204494de4bf5f180700006fa8 xfcstatuscode: 200 xfcupstreamservicetime: 2781 xfcreqcosttime: 2782 xfcreqarrivetime: 1748333160021 xfcrespstarttime: 1748333162803 connection: close body: hello world component: faascf

本文介绍如何创建函数、管理函数。 创建函数 1. 登录CDN控制台。 2. 单击左侧导航栏【边缘函数】【函数管理】，进入【函数管理】页面。 3. 单击右上角的【+创建函数】。 4. 进入创建函数页，填写【函数名称】、选择【函数规格】和【语言类型】，填写完成后单击【创建触发器】。 参数 说明 函数名称 请输入函数名称，目前只支持小写字母、数字、下划线，开头结尾只允许小写字母和数字。名称长度264字符。函数名称创建后无法修改。 函数规格 函数代码单次执行过程中，CPU运行时间最大值。支持10ms、50ms、100ms三种规格。 语言类型 当前支持JavaScript，后续会继续扩展更多编程语言。 触发器 边缘函数需要域名作为入口供客户端访问，域名使用已配置的CDN加速域名。 函数模板 当前根据常见客户场景提供预制代码，帮助您快速体验并为您的CDN加速域名扩展自定义功能。 选择函数模板部署完成后，您可以从函数详情>版本与发布>快速编辑进行代码开发、测试与部署。 5. 进入创建触发器页，选择【作用域名】，将函数绑定到具体的域名上。 参数 说明 触发器类型 用于触发函数计算的入口，目前支持HTTP触发器：使用您的CDN加速域名作为入口供客户端访问。 作用域名 当您创建HTTP触发器时，需要关联您名下的加速CDN加速域名。 HTTP路由 函数根据具体路由规则生效，支持通配符配置，例如：/h5/abc 旁路触发 旁路触发生效后，符合规则的客户端请求将被发送到边缘函数执行，随后继续执行CDN加速域名配置并回源，适合于一些鉴权校验或日志打点的场景。旁路触发关闭时，符合规则的客户端请求将被发送到边缘函数，执行个性化处理。 注意 边缘函数目前仅允许在特定资源池使用。创建函数触发器时，首先确保您要绑定的域名为CDN加速且状态为已启用的域名，若满足上述条件后仍无法选到域名，说明该域名未使用边缘函数的特定资源池，请提交工单申请将域名迁移到边缘函数特定资源池后再创建触发器。 6. 选择合适的【函数模板】，单击页面右下角的【创建函数】提交创建函数的请求。