Azure Blobトリガーの処理失敗時にメール通知する のバックアップ(No.4) - 闘うITエンジニアの覚え書き

Azure Blobトリガーから起動される関数アプリがコケた時にメール通知を行う方法について記載する。

Azure Functions の異常を検知する では、Azure Monitor を使用してメール通知を行ったが、Azure Monitor ではメールの本文を指定して送信する事ができない為、
ここでは有害キュー(webjobs-blobtrigger-poison)にトリガーを設定して関数アプリからメール送信を行う方法について記載する。

また、関数アプリの言語は従量課金プランが可能な Node.js を使用している。

[補足]

• Blobトリガーで起動される関数では何回目のリトライか等が判断できない為、有害キューにメッセージが出力されたタイミングで起動する別の関数を作成している。
• 正常終了させてしまうとキューからメッセージが削除されてしまう為、わざとエラーにしている。

※複数（５回のリトライ回数分）の通知が来ても良いなら ログの出力形式だけ決めておいて Azure Monitor から通知しても良いと思う。

blobトリガー用の関数アプリに含めてしまう場合（Go）の例

import (
     :
    "github.com/sendgrid/sendgrid-go"
    "github.com/sendgrid/sendgrid-go/helpers/mail"
)

:

/**
 * エラーのメール通知.
 */
func blobErrorHandler(w http.ResponseWriter, r *http.Request) {

    var invokeReq InvokeRequest
    d := json.NewDecoder(r.Body)
    decodeErr := d.Decode(&invokeReq)
    if decodeErr != nil {
        http.Error(w, decodeErr.Error(), http.StatusBadRequest)
        return
    }   
    printInfo("queue metadata: %v", invokeReq.Metadata)

    dequeueCount := fmt.Sprintf("%v",invokeReq.Metadata["DequeueCount"])
    if dequeueCount == "1" {

        queueItem := invokeReq.Data["queueItem"].(string)

        SENDGRID_API_KEY  := getEnv("SENDGRID_API_KEY", "") 
        MAIL_FROM_ADDRESS := getEnv("MAIL_FROM_ADDRESS", "") 
        MAIL_TO_ADDRESS   := getEnv("MAIL_TO_ADDRESS", "") 

        // 見やすいように過剰エスケープを調整
        queueItem = strings.TrimRight(queueItem, "\"")
        queueItem = strings.TrimLeft(queueItem, "\"")
        queueItem = strings.Replace(queueItem, "\\n", "\n", -1) 
        queueItem = strings.Replace(queueItem, "\\\"", "\"", -1) 
        queueItem = strings.Replace(queueItem, "\\\\\"", "", -1) 
        printInfo("queue message(Value): %v", queueItem)

        from := mail.NewEmail("トリガー異常監視", MAIL_FROM_ADDRESS)
        subject := "Blobトリガーでエラーが発生しています"
        to := mail.NewEmail(MAIL_TO_ADDRESS, MAIL_TO_ADDRESS)
        plainTextContent := fmt.Sprintf("有害キューに出力された情報:\n%s", queueItem)
        htmlContent      := fmt.Sprintf("有害キューに出力された情報:<br /><pre style=\"border: 1px solid #333; padding: 10px;\">%s</pre>", queueItem)
        message := mail.NewSingleEmail(from, subject, to, plainTextContent, htmlContent)
        client := sendgrid.NewSendClient(SENDGRID_API_KEY)
        response, err := client.Send(message)
        if err != nil {
            printError("[MAILSEND ERROR] %v", err)
        } else if (response.StatusCode == 202) {
            printInfo("[MAILSEND SUCCESS]")
        } else {
            printError("[MAILSEND ERROR] status: %v, body: %v, header: %v", response.StatusCode, response.Body, response.Headers)
        }   
    }

    // 正常終了してしまうとキューから消えてしまうので、あえてエラーにしておく
    //invokeResponse := InvokeResponse{Logs: []string{"Received blob trigger error."} }
    //js, err := json.Marshal(invokeResponse)
    //if err != nil {
    //  http.Error(w, err.Error(), http.StatusInternalServerError)
    //  return
    //}
    //w.Header().Set("Content-Type", "application/json")
    //w.Write(js)
    http.Error(w, "process blobErrorHandler.", http.StatusInternalServerError)
}

 :

func main() {
    httpInvokerPort, exists := os.LookupEnv("FUNCTIONS_HTTPWORKER_PORT")
    if exists {
        printInfo("FUNCTIONS_HTTPWORKER_PORT: " + httpInvokerPort)
    }
    mux := http.NewServeMux()
    mux.HandleFunc("/BlobTrigger", blobTriggerHandler)
    mux.HandleFunc("/RerunAll"   , rerunAllHandler)
    mux.HandleFunc("/ErrorNotice", blobErrorHandler)   // 追加
    log.Println("Go server Listening...on httpInvokerPort:", httpInvokerPort)
    log.Fatal(http.ListenAndServe(":"+httpInvokerPort, mux))
}

メール通知イメージ