检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
本案例展示了函数工作流服务配合使用云日志服务LTS实现日志云端处理并转储消息到LTS的功能。 场景介绍 通过云日志服务LTS，快速完成ECS等服务器的任务运行日志的采集、加工和转换。 通过函数工作流服务中的函数创建LTS触发器获取日志数据，经由自定义函数对日志中的关键信息进行分析和
配置函数流的子流程控制器组件 函数工作流服务可以把一些“函数流”作为“子流程”组合成一个新的函数流，这样可以抽取出一些函数流作为公共流进行使用，减少函数流的重复编排。 约束与限制 通过数据工坊DWR服务创建的函数流，在函数工作流控制台只能查看，不能编辑和删除，相关操作请在DWR服务中执行。
Administrator系统角色，无需手动取消） VPC Administrator：虚拟私有云服务管理员。 Server Administrator：服务器管理员。 上传和使用自定义模型时必选。 SFS FullAccess 弹性文件服务所有权限。 上传和使用自定义模型挂载SFS文件系统时必选。
配置函数的触发器 FunctionGraph支持的触发事件 使用TIMER定时触发器 本节介绍创建定时触发器，按照设置的频率，定期触发函数运行，供用户了解定时触发器的使用方法。 使用APIG专享版触发器 本节介绍创建APIG触发器，使用API调用函数运行，供您了解APIG触发器的
使用分布式消息服务Kafka触发器 本节介绍如何使用函数工作流控制台创建Kafka触发器，以实现FunctionGraph对Kafka实例中指定Topic的新消息进行定期轮询。FunctionGraph会将轮询得到的消息作为参数，用于调用相应函数。 关于Kafka触发器的事件源介绍，请参见支持的事件源。
Administrator系统角色，无需手动取消） VPC Administrator：虚拟私有云服务管理员。 Server Administrator：服务器管理员。 必选。 SFS FullAccess 弹性文件服务所有权限。 上传和使用自定义模型挂载SFS文件系统时必选。 SFS Turbo
上传与加载自定义模型 进阶使用：使用ECS作为NFS服务器实现多用户资源隔离 如需实现多用户使用场景下的资源隔离，FunctionGraph函数支持挂载ECS服务器作为文件系统来源，通过设置共享NFS路径可有效管理多用户模型资源，可通过以下操作实现： 购买ECS服务器 设置ECS下的NFS共享 在Stable
日志，处理日志并发结果写入test-1121。函数B代码样例请参考lts_cleanse.py。 在云日志服务配置Agent，快速将ECS等服务器上日志采集到指定的日志组，配置过程请参考安装ICAgent。 图1 流程图 创建委托 登录统一身份认证服务控制台。 在统一身份认证服务
等各项配置。 约束与限制 HTTP函数当前不区分编程语言，函数执行入口必须在bootstrap文件中设置，用户直接写启动命令，端口统一开放成8000，绑定IP为127.0.0.1。 bootstrap文件是HTTP函数的启动文件，HTTP函数仅支持读取bootstrap 作为启动
配置函数流的循环控制器组件 循环控制器组件可以用来对输入数组中每个元素进行循环处理，每次循环会执行一次循环内部的子流程或函数。 约束与限制 通过数据工坊DWR服务创建的函数流，在函数工作流控制台只能查看，不能编辑和删除，相关操作请在DWR服务中执行。 循环节点内部子流程需要满足如下规则：
Administrator系统角色，无需手动取消） VPC Administrator：虚拟私有云服务管理员。 Server Administrator：服务器管理员。 必选。 SFS FullAccess 弹性文件服务所有权限。 上传和使用自定义模型和节点挂载SFS文件系统时必选。 SFS Turbo
配置函数流的时间等待控制器组件 时间等待控制器组件可以用来控制当前子流程或函数在指定时间延迟后再调用下一个子流程或函数。 约束与限制 通过数据工坊DWR服务创建的函数流，在函数工作流控制台只能查看，不能编辑和删除，相关操作请在DWR服务中执行。 时间等待控制器组件后面可以连接0个
公共读：任何用户都可以对桶内对象进行读操作。 公共读写：任何用户都可以对桶内对象进行读/写/删除操作。 私有 默认加密 必选参数。 服务器端加密是指OBS服务端对客户端上传到OBS的对象进行加密存储，开启后需要选择加密密钥。 关闭 归档数据直读 必选参数。 通过归档数据直读，
示例代码 连接DCS单机、主备、读写分离、Proxy集群实例 连接DCS集群实例 代码解读 父主题： 使用FunctionGraph函数访问Redis数据
准备 该场景涉及微服务与后端服务的调用，因此需要提前准备好对应的后端服务。用户可以使用自己搭建的后端服务，也可以使用华为云提供的云服务。 若后端服务需要通过虚拟私有云（VPC）访问，函数需要进行额外配置，若可以通过公网访问后端服务，可以跳过以下步骤2和步骤3。 创建Java函数（
配置函数流的开始控制器组件 函数流的开始控制器组件是用于标识流程的开始。 约束与限制 通过数据工坊DWR服务创建的函数流，在函数工作流控制台只能查看，不能编辑和删除，相关操作请在DWR服务中执行。 每个函数流必须以“开始节点”作为流程开始且只能有一个“开始节点”，同时以“结束节点”作为流程结束。
配置和查看函数的调用日志 FunctionGraph函数实现了与云日志服务的对接，用户无需任何配置，即可查询函数日志信息。 在FunctionGraph函数控制台，可以通过以下两种方式查看函数日志。 在测试页签查看日志 函数创建完成后，可以测试函数，在执行结果页，可以查看函数测试日志。操作步骤请参见在线调试函数。
上传与使用自定义模型 进阶使用：使用ECS作为NFS服务器实现多用户资源隔离 如需实现多用户使用场景下的资源隔离，FunctionGraph函数支持挂载ECS服务器作为文件系统来源，通过设置共享NFS路径可有效管理多用户模型资源，可通过以下操作实现： 购买ECS服务器 设置ECS下的NFS共享 在AI对话应用中挂载ECS
配置函数流的异常处理控制器组件 异常处理控制器组件用于控制函数执行失败后的下一步流程，当函数流里面的函数执行异常时，可以通过“异常处理”来处理执行失败的函数并可添加重试。函数执行失败可分为多种情况：函数执行异常；函数内部业务失败并在返回内容中添加了错误码，例如status，200代表成功，500和404等代表失败。
Not Acceptable 服务器生成的响应无法被客户端所接受。 407 Proxy Authentication Required 用户必须首先使用代理服务器进行验证，这样请求才会被处理。 408 Request Timeout 请求超出了服务器的等待时间。 409 Conflict
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
