文档首页/ 函数工作流 FunctionGraph/ 最佳实践/ 函数+LTS：日志实时过滤/ 构建程序
更新时间：2024-08-21 GMT+08:00
查看PDF
分享

构建程序

前提条件

（1）函数中的IP地址为LTS的接入点，获取接入点IP方法如下：
  1. 登录云日志服务 LTS控制台，在左侧导航栏选择“主机管理 > 主机”；
  2. 在页面右上方，单击“安装ICAgent”；
  3. 在弹出的“安装ICAgent”窗口中获取接入点IP。
    图1 接入点IP

（2）函数中的log_group_id和log_stream_id变量值的获取，请参考获取账号ID、项目ID、日志组ID、日志流ID。

（3）制作函数B需要的 lts 依赖包，具体添加依赖方法请参考如何在函数平台创建依赖包和如何为函数添加依赖包。制作依赖包时可以参考命令“pip install huaweicloudsdklts”。同时，示例代码中包含了已适用于python3.9的huaweicloudsdklts依赖。

创建功能函数

创建实现日志提取功能的函数，将示例代码包上传。创建过程请参考创建事件函数，运行时语言选择“Python3.9”，委托名称选择创建委托中的“LtsOperation”。

创建函数A，代码样例请参考write_log.py。函数A代码中host、log_group_id和log_stream_id使用对应接入点和创建好的日志组test-1206、日志流test-206的ID，如图2所示。

图2 write_log.py

创建函数B，代码样例请参考lts_cleanse.py。函数B代码中host、log_group_id和log_stream_id使用对应接入点和创建好的日志组test-1121、日志流test-1121的ID，并为函数B添加依赖huaweicloudsdklts，如图3和图4所示。

图3 lts_cleanse.py
图4 为函数B添加依赖包

函数实现的功能是：将收到的日志事件数据进行base64解码，然后提取出包含“WRN”、“WARN”、“ERR”或“ERROR”关键字的告警日志，将此级别的日志投递至创建好的LTS日志流中集中存储。可根据您的业务日志的具体内容配置相应的日志提取条件。