logstash配置
    mkdir -p /data/logalert/data
    mkdir -p /data/logalert/scripts
    yum install -y python3
    pip3 install requests

    1. //[root@keep-nxl7x scripts]# cat /etc/logstash/conf.d/logstash.conf
    2. input {
    3.   file {
    4.   path => "/data-gpu/podlog/20220412/batch/*.log"
    5.   max_open_files => 20000
    6. }
    7. file {
    8.   path => "/data-cpu/podlog/20220412/batch/*.log"
    9.   max_open_files => 20000
    10. }
    11. file {
    12.   path => "/data/podlog/20220412/batch/*.log"
    13.   max_open_files => 20000
    14. }
    16. }
    18. output {
    19.   if 'cudaGetDeviceCount' in [message] or 'UserCenterError' in [message] {
    20.     file {
    21.     path => "/data/logalert/data/%{+yyyyMMddHHmmss}.log"
    22.     codec => line { format => "%{message}"}
    23. }
    24. }
    25. }
    1. #!/usr/bin/python3
    2. # -*- coding: utf-8 -*-
    4. import requests, json, sys
    7. def msg(text,cluster):
    8.     json_text={
    9.         "msg_type":"text",
    10.         "content":{
    11.             "msg":"任务日志关键字告警",
    12.             "text":cluster+"\n"+text
    13.         }
    14.     }
    15.     print(requests.post(api_url,json.dumps(json_text),headers=headers).content)
    17.     if __name__=='__main__':
    18.         api_url = 'https://open.feishu.cn/open-apis/bot/v2/hook/e9a0edf5-46f2-44c4-8b67-b2d12a8579e2'
    19.         headers = {'Content-Type': 'application/json;charset=utf-8'}
    20.         if sys.argv[1]:
    21.             text = sys.argv[1]
    22.             if sys.argv[2]:
    23.                 cluster = sys.argv[2]
    24.                 title = "任务日志关键字告警"
    25.                 cluster = cluster+title
    26.     msg(text,cluster)