通過Gin框架對接阿里云SLS日志服務(wù)，查詢服務(wù)日志，你學(xué)會了嗎？

作者：院長技術(shù) 2024-11-12 09:13:01

日志服務(wù)一站式提供數(shù)據(jù)采集、加工、查詢與分析、可視化、告警、消費與投遞等功能，全面提升研發(fā)、運維、運營、安全等場景的數(shù)字化能力。項目代碼

阿里云SLS

日志服務(wù) Simple Log Service 是服務(wù)于阿里云客戶以及阿里云集團(tuán)內(nèi)部自用的云原生觀測與分析，一站式可觀測數(shù)據(jù)的 Data to Insight 平臺，為 Log、Metric、Trace 等數(shù)據(jù)提供大規(guī)模、低成本、實時的平臺化服務(wù)。日志服務(wù)一站式提供數(shù)據(jù)采集、加工、查詢與分析、可視化、告警、消費與投遞等功能，全面提升研發(fā)、運維、運營、安全等場景的數(shù)字化能力。

項目代碼

package main


import (
  "fmt"
  "github.com/aliyun/aliyun-log-go-sdk"
  "github.com/gin-gonic/gin"
  "net/http"
  "time"
)


func main() {
  router := gin.Default()


  router.GET("/download-logs", func(c *gin.Context) {
    // 地區(qū)
    endpoint := "cn-beijing.log.aliyuncs.com"
    // key
    accessKeyID := "LTAI5tShzYy1VMGR17H"
    // 密鑰
    accessKeySecret := "QELEeTCudJHYhYY3mpuD"


    provider := sls.NewStaticCredentialsProvider(accessKeyID, accessKeySecret, "")
    client := sls.CreateNormalInterfaceV2(endpoint, provider)


    ProjectName := "dean"
    LogStoreName := "nginx"


    logstore, err := client.GetLogStore(ProjectName, LogStoreName)
    if err != nil {
      fmt.Println("出現(xiàn)報錯了")
      panic(err)
    }
    fmt.Println("get logstore successfully:", logstore.Name)


    // 設(shè)置查詢的時間范圍
    fromTime := time.Now().Unix() - (60 * 60 * 24) // 24小時之前
    toTime := time.Now().Unix()                    // 當(dāng)前時間


    // 設(shè)置查詢的參數(shù)
    query := "*"
    line := int64(100) // 每頁日志條數(shù)
    offset := int64(0) // 偏移量


    // 獲取日志
    resp, err := logstore.GetLogs("", fromTime, toTime, query, line, offset, false)
    if err != nil {
      fmt.Println(err)
      c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to get logs"})
      return
    }
    logs := resp.Logs


    // 將所有日志轉(zhuǎn)換為JSON格式返回
    c.JSON(http.StatusOK, logs)


    //// 設(shè)置文件名（可以根據(jù)需要自定義）
    //filename := "access_log_" + time.Now().Format("20060102150405") + ".txt"
    //
    //// 設(shè)置HTTP頭信息，指示這是一個文件下載響應(yīng)
    //c.Header("Content-Disposition", "attachment; filename=\""+filename+"\"")
    //c.Header("Content-Type", "text/plain")
    //
    //// 寫入文件內(nèi)容
    //c.String(http.StatusOK, logs)


    // 設(shè)置下載相關(guān)的頭部信息
    c.Header("Content-Description", "File Transfer")
    c.Header("Content-Disposition", "attachment; filename=logs.txt")
    c.Header("Content-Type", "application/octet-stream")


    // 將日志內(nèi)容寫入響應(yīng)體
    for _, log := range resp.Logs {
      c.Writer.Write([]byte(fmt.Sprintf("%v\n", log)))
    }


  })


  router.Run(":8080")
}

啟動代碼程序：

圖片