My External Storage

Jan 17, 2018 - 5 minute read - Comments - Go Lambda AWS

AWS Lambda Go早めぐり(LambdaContext, Logging, Error...)

AWS LambdaでGoが正式にサポートされた！！

AWS Lambda Supports Go
https://aws.amazon.com/jp/about-aws/whats-new/2018/01/aws-lambda-supports-go/

aws/aws-lambda-go
https://github.com/aws/aws-lambda-go

2018/01/17現在、日本語版はまだだが、英語のDocsは公開されているので、それを基にGoでLambdaを動かす。

Programming Model for Authoring Lambda Functions in Go
https://docs.aws.amazon.com/en_us/lambda/latest/dg/go-programming-model.html

Announcing Go Support for AWS Lambda
https://aws.amazon.com/jp/blogs/compute/announcing-go-support-for-aws-lambda/

TL;DR

  • 基本的にコードファイルひとつで実行バイナリまで作れる
  • ハンドラ定義は5パターンのみ（TIn, TOutはencoding/jsonが使える構造体）
  • 渡されるContextの中にはLambdaContextが入っている
  • ログはfmtやlogを使っていればよしなにしてくれる
  • エラー処理はerrorやpanicなど標準のものが使える
  • os.Getenvで環境変数の確認ができる

実装したコードは以下
https://github.com/budougumi0617/sandbox-aws-lambda-go/blob/master/hello-lambda/main.go

package main

import (
	"context"
	"errors"
	"fmt"
	"log"
	"os"

	"github.com/aws/aws-lambda-go/events"
	"github.com/aws/aws-lambda-go/lambda"
	"github.com/aws/aws-lambda-go/lambdacontext"
)

func HelloLambdaHandler(ctx context.Context, config events.ConfigEvent) (string, error) {
	lc, ok := lambdacontext.FromContext(ctx)
	if !ok {
		return "", errors.New("Cannot find LambdaContext")
	}

	log.Printf("log:InvokedFunctionArn = %s\n", lc.InvokedFunctionArn)
	fmt.Printf("fmt:InvokedFunctionArn = %s\n", lc.InvokedFunctionArn)
	log.Printf("config version is %v\n", config.Version)
	log.Printf("\"%s\" executes on \"%s\".\n", os.Getenv("LAMBDA_TASK_ROOT"), os.Getenv("AWS_EXECUTION_ENV"))

	return "function finished", nil
}

func main() {
	lambda.Start(HelloLambdaHandler)
}

前提・準備

とりあえず動かすだけなのでzipでLambdaにコードをアップしてテストイベントで実行してみる。 事前に空のLambda関数を作っておく。自分の設定は以下。

  • コードエントリタイプ
    • .ZIPファイルをアップロード
  • ランタイム
    • Go 1.x
  • ハンドラ
    • main
  • 実行ロール
    • IAMで空のロールを作っておきそれを使う
  • テストイベント
    • イベントテンプレートのAWS Config Change Triggered Ruleの値を少し変えたものを用意した。
{
  "configRuleId": "config-rule-0123456",
  "version": "6.17",
  "configRuleName": ...
}

もろもろのGoの開発環境は済んでいると想定する。

ハンドラ定義は5パターンのみ（TIn, TOutはencoding/jsonが使える構造体）

Lambda Function Handler (Go)
https://docs.aws.amazon.com/en_us/lambda/latest/dg/go-programming-model-handler-types.html

ハンドラにはcontext.Contextやイベント情報が渡される。定義出来るパターンは以下。

  • func ()
  • func () error
  • func (TIn), error
  • func () (TOut, error)
  • func (context.Context) error
  • func (context.Context, TIn) error
  • func (context.Context) (TOut, error)
  • func (context.Context, TIn) (TOut, error)

引数は0〜2個まで。引数を指定するときはcontext.Contextを第一引数にするのが必須。
戻り値も0〜2個。最終戻り値はerrorになる形。
TInとTOutはencoding/jsonでUnmarshalできる必要がある。
AWS内のイベントは既に構造体が定義されているので、それをつかえる。

https://godoc.org/github.com/aws/aws-lambda-go/events

今回はevents.ConfigEventを使ってみた。

package events

// ConfigEvent contains data from an event sent from AWS Config
type ConfigEvent struct {
  ...
  Version          string `json:"version"`
}

渡されるContextの中にはLambdaContextが入っている

The Context Object (Go)
https://docs.aws.amazon.com/en_us/lambda/latest/dg/go-programming-model-context.html

https://godoc.org/github.com/aws/aws-lambda-go/lambdacontext

ハンドラに渡されるcontext.Contextの中には、LambdaContextが入っていて、AWSの情報がよしなに入っている。

	lc, ok := lambdacontext.FromContext(ctx)
	if !ok {
		return "", errors.New("Cannot find LambdaContext")
	}
	fmt.Printf("InvokedFunctionArn = %s\n", lc.InvokedFunctionArn) // InvokedFunctionArn = arn:aws:lambda:ap-no...

lambdacontext.NewContextを使って 自分でContextの中にLambdaContextを入れることも出来る(ハンドラ内でgoroutine回したりする時用？)

ログはfmtやlogを使っていればよしなにしてくれる

Logging (Go）
https://docs.aws.amazon.com/en_us/lambda/latest/dg/go-programming-model-logging.html

ログは他の言語で実装したとき同様標準出力に出力すればCloudWatchに保存される。logを使えばタイムスタンプを付与しておく事もできる。

log.Printf("log:InvokedFunctionArn = %s\n", lc.InvokedFunctionArn) // 2018/01/16 23:07:46 log:Invoked...
fmt.Printf("fmt:InvokedFunctionArn = %s\n", lc.InvokedFunctionArn) // fmt:Invoked...

エラー処理はerroやpanicなど標準のものが使える

Function Errors (Go)
https://docs.aws.amazon.com/en_us/lambda/latest/dg/go-programming-model-errors.html

エラー処理は普通のGoとあまり変わらないようだ。ちゃんと試せてはいない。 panicを仕込むとStackTraceなども取れるらしい？

以下、上記公式の内容を引用。

{
    "errorMessage": "Something went wrong",
       "errorType": "errorString",
    "stackTrace": [
            {
            "path": "github.com/aws/aws-lambda-go/lambda/function.go",
            "line": 27,
            "label": "(*Function).Invoke.function"
        },
 ...

    ]
}

os.Getenvで環境変数の確認ができる

Using Environment Variables (Go)
https://docs.aws.amazon.com/en_us/lambda/latest/dg/go-programming-model-env-variables.html

他の言語と同様、os.Getenvで環境変数を取得できる。

fmt.Printf("\"%s\" executes on \"%s\".\n", os.Getenv("LAMBDA_TASK_ROOT"), os.Getenv("AWS_EXECUTION_ENV"))  // "/var/task" executes on "".

ちなみにAWS_EXECUTION_ENVがどうなるか書いてなかったので、興味本位で見ようと思ったら本当に設定されてなかった（？）

Environment Variables Available to Lambda Functions
https://docs.aws.amazon.com/en_us/lambda/latest/dg/current-supported-versions.html#lambda-environment-variables

2018/01/17現在、用意されている内容はこれくらい。

デプロイ・動作確認

上記内容を全て実装したのが、冒頭に記載した以下のリンク先のコード
https://github.com/budougumi0617/sandbox-aws-lambda-go/blob/master/hello-lambda/main.go

これをAWS Lambda上で動かしてみる。Goの(一番簡単な方法をする)場合はビルドしてzipに入れてアップするだけ。 Linux用にビルドするのと、「前提・準備」で設定した「ハンドラ」と同じ名前のバイナリをするところだけ注意する。 これをLambdaのWebコンソールからアップロードすれば実行できる

$ GOOS=linux go build -o main
$ zip deployment.zip main

作成したテストイベントで実行した結果がこちら。

START RequestId: XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXX Version: $LATEST
2018/01/16 23:07:46 log:InvokedFunctionArn = arn:aws:lambda:ap-northeast-1:XXXXXXXXXXXXXX:function:myFirstLambda
fmt:InvokedFunctionArn = arn:aws:lambda:ap-northeast-1:XXXXXXXXXXXX:function:myFirstLambda
2018/01/16 23:14:26 config version is 6.17
2018/01/16 23:14:26 "/var/task" executes on "".
END RequestId: XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXX
REPORT RequestId: XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXX	Duration: 0.59 ms	Billed Duration: 100 ms 	Memory Size: 128 MB	Max Memory Used: 27 MB

Lambdaの実行結果

動いた！LambdaContextの中身も確認できている。

終わりに

この発表を聞いて初めてAWSの無料枠に入ったレベルだったので、今回はひとつのLambda内に閉じた実装だけ確かめた。 Goでの実装はコードひとつだけでビルドできるので、非常に簡単だった。 (正直コーディングの時間より初回登録時の電話認証のほうが時間かかっている。)
自分はあまりクラウドに詳しくないのだが、これくらい小さく始められるのは嬉しい。CloudWatchにログ流したり、別のサービスのイベント拾ったり、少しずつ視野を広げられそう。
設定ファイルを置けばAWS CodePipelineなどを使って自動デプロイなども出来るらしいので、後日確かめてみたい。 (冒頭のブログに詳しく書かれている。)

Creating a Deployment Package (Go）
https://docs.aws.amazon.com/en_us/lambda/latest/dg/lambda-go-how-to-create-deployment-package.html

参考

aws/aws-lambda-go
https://github.com/aws/aws-lambda-go

GoDoc:aws/aws-lambda-go
https://godoc.org/github.com/aws/aws-lambda-go

AWS Lambda Supports Go
https://aws.amazon.com/jp/about-aws/whats-new/2018/01/aws-lambda-supports-go/

Announcing Go Support for AWS Lambda
https://aws.amazon.com/jp/blogs/compute/announcing-go-support-for-aws-lambda/

Programming Model for Authoring Lambda Functions in Go
https://docs.aws.amazon.com/en_us/lambda/latest/dg/go-programming-model.html

Creating a Deployment Package (Go）
https://docs.aws.amazon.com/en_us/lambda/latest/dg/lambda-go-how-to-create-deployment-package.html

AWS SAMを利用してGolangなLambdaをデプロイする
https://qiita.com/ikeisuke/items/3c0c422888ae8ae09831

awsのlamdaがGo言語対応したので雑にsampleを動かしてみる
https://qiita.com/ieee0824/items/5bf3f9649f2378c6f2e5

budougumi0617/sandbox-aws-lambda-go
https://github.com/budougumi0617/sandbox-aws-lambda-go

関連記事