Cloud Functionsのエラー通知
エラーに会いに行く
Cloud Functionsでエラー検知したいときありますよね。
その仕組みを今回作ります。
トピック作成
まずは、Pub/Sub→トピックから通知用の「トピック作成」をします。
コンボ開始です。
シンク作成
次にロギング→ログルーターでシンクを作成します。
名前と説明を決め、シンクの宛先で「Cloud Pub/Sub トピック」を選択します。
「シンクに含めるログの選択」で下記のように入力します。
タイミングはそこまでシビアではないので、落ち着いて入力してもらえればと思ってます。
内容はfunction_name以外はそのままでいいと思います。
resource.type="cloud_function"
resource.labels.function_name="SampleFunction"
severity>=ERROR
CloudFunctions作成
あとは、起き攻めよろしく、エラー通知用にトリガーのタイプを「Cloud Pub/Sub」にしたCloudFunctionsを作成します。
単純にSlack通知します。
// Package p contains a Pub/Sub Cloud Function.
package p
import (
"context"
"crypto/tls"
"fmt"
"log"
"net/http"
"net/url"
)
const WebHook = "Slack WebHook Url"
// PubSubMessage is the payload of a Pub/Sub event. Please refer to the docs for
// additional information regarding Pub/Sub events.
type PubSubMessage struct {
Data []byte `json:"data"`
}
// HelloPubSub consumes a Pub/Sub message.
func HelloPubSub(ctx context.Context, m PubSubMessage) error {
err := slackNotify(WebHook, string(m.Data))
if err != nil {
log.Printf("err %v",err)
return err
}
return nil
}
func slackNotify(webhook string, data string) error {
payload := fmt.Sprintf("{'text': '<!channel> \n```%s```'}", data)
values := url.Values{}
values.Add("payload", payload)
http.DefaultTransport.(*http.Transport).TLSClientConfig = &tls.Config{InsecureSkipVerify: true}
_, err := http.PostForm(webhook, values)
if err != nil {
return err
}
return nil
}
現場からは以上です。
Author And Source
この問題について(Cloud Functionsのエラー通知), 我々は、より多くの情報をここで見つけました https://qiita.com/xanadou/items/6bd3888b5521d66057bd著者帰属:元の著者の情報は、元のURLに含まれています。著作権は原作者に属する。
Content is automatically searched and collected through network algorithms . If there is a violation . Please contact us . We will adjust (correct author information ,or delete content ) as soon as possible .