Alexa語音整合Splunk實作網路自動化查詢

const LaunchHandler = {
  canHandle(handlerInput) {
    return handlerInput.requestEnvelope.request.type === 'LaunchRequest';
  },
  handle(handlerInput) {
    const speechText = '歡迎使用Splunk查詢工具，您可以詢問介面狀態。';
    return handlerInput.responseBuilder
      .speak(speechText)
      .withShouldEndSession(false)
      .getResponse();
  }
};

const splunkintentHandler = {
  canHandle(handlerInput) {
    return handlerInput.requestEnvelope.request.type === 'IntentRequest' &&
           handlerInput.requestEnvelope.request.intent.name === 'splunkintent';
  },
  async handle(handlerInput) {
    var inp_status = handlerInput.requestEnvelope.request.intent.slots.status.value;
    var outputSpeech = "";
    var url = 'http://13.59.112.54/splunk/runquery';
    var data = '';
    // 根據輸入狀態構建查詢資料
    if (inp_status == "up") {
      data = {"query": "search index=\"main\" earliest=0 | where interface_name=\"Loopback45\" | dedup interface_name,router_name | where interface_status=\"up\" | stats values(interface_name) values(interface_status) by router_name | table router_name"};
    } else if (inp_status == "down") {
      data = {"query": "search index=\"main\" earliest=0 | where interface_name=\"Loopback45\" | dedup interface_name,router_name | where interface_status!=\"up\" | stats values(interface_name) values(interface_status) by router_name | table router_name"};
    }
    // 傳送POST請求至Splunk API
    var res;
    var router_array = [];
    await POSTdata(url, data)
      .then((response) => {
        res = JSON.parse(response);
        var arr_len = res.result.length;
        for (var i = 0; i < arr_len; i++) {
          router_array.push(res.result[i].router_name);
        }
      })
      .catch((err) => {
        outputSpeech = '錯誤：' + err.message;
      });
    // 構建回應語音
    var count = router_array.length;
    for (let i = 0; i < count; i++) {
      if (i === 0) {
        outputSpeech = outputSpeech + '狀態為' + inp_status + '的路由器有：' + router_array[i] + ',';
      } else if (i === count - 1) {
        outputSpeech = outputSpeech + '以及' + router_array[i] + '。';
      } else {
        outputSpeech = outputSpeech + router_array[i] + ', ';
      }
    }
    return handlerInput.responseBuilder
      .speak(outputSpeech)
      .withShouldEndSession(false)
      .getResponse();
  }
};

const ErrorHandler = {
  canHandle() {
    return true;
  },
  handle(handlerInput, error) {
    console.log(`錯誤處理：${error.message}`);
    return handlerInput.responseBuilder
      .speak('抱歉，我無法理解您的指令，請再試一次。')
      .reprompt('抱歉，我無法理解您的指令，請再試一次。')
      .getResponse();
  }
};

# 初始化環境，匯入必要的函式庫
import re
import netmiko
import time
import datetime
import math
from threading import Thread
import logging
import threading
from random import randrange
import itertools
import sys
import base64

#### 內容解密：
- `import re`：匯入正規表示式函式庫，用於字串匹配和處理。
- `import netmiko`：匯入Netmiko函式庫，用於與網路裝置建立連線並執行命令。
- `import time` 和 `import datetime`：匯入時間相關的函式庫，用於處理時間和日期。
- `from threading import Thread`：匯入執行緒函式庫，用於平行執行任務。
- `import logging`：匯入日誌記錄函式庫，用於記錄指令碼執行過程中的事件。

class LineCheck:
    def __init__(self):
        self.state = 0
    
    def __call__(self, line):
        if line and not line[0].isspace():
            self.state += 1
        return self.state

def parse_config(config):
    rlist = []
    for _, group in itertools.groupby(config.splitlines(), key=LineCheck()):
        templist = list(group)
        if len(templist) == 1 and "!" in str(templist):
            continue
        rlist.append(templist)
    return rlist

def get_interface_name(interface_details):
    m = re.search('(^[a-zA-Z0-9/-]*) is ', interface_details)
    if m:
        return m.group(1).strip(",")
    return 'NULL'

def fetch_router_interface_stats(device_type, routerip, username, password, timestamp, enable_passwd=''):
    # 建立連線
    router = {
        'device_type': device_type,
        'ip': routerip,
        'username': username,
        'password': password,
        'secret': enable_passwd
    }
    try:
        net_connect = netmiko.ConnectHandler(**router)
        print(f"成功連線路由器 {routerip}")
    except Exception as ex:
        print(f"連線路由器 {routerip} 失敗")
        print(ex)
        return
    
    # 取得介面統計資訊
    router_stats = []
    interface_details = net_connect.send_command("show interfaces")
    parsed_config = parse_config(interface_details)
    
    for item in parsed_config:
        interface_name = get_interface_name('\n'.join(item))
        if interface_name in fetch_interface_summary(interface_details):
            router_stats.append(fetch_interface_stats('\n'.join(item), interface_name))
    
    # 寫入檔案
    with open(abs_filename, "a+") as text_file:
        for interface_stats in router_stats:
            text_file.write(f"{timestamp},router_name={router_hostname},interface_name={interface_stats['interface_name']},...")
            text_file.write('\n')
    
    net_connect.disconnect()
    return

def fetch_interface_stats(interface_details, interface_name):
    stats = {}
    # 解析介面狀態、錯誤計數等資訊
    m = re.search('([\d]+) interface resets', interface_details)
    if m:
        stats['interface_resets'] = int(m.group(1))
    else:
        stats['interface_resets'] = -1
    
    # 其他統計資訊解析...
    
    return stats