AWS 請求通知 BOT を AWS Lambda + AWS SDK + Go で作る~ SDK調査編 ~

func GetOpenexchangeratesJpy(sess *session.Session) float64 {
	// Base URL: https://docs.openexchangerates.org
	base := "https://openexchangerates.org/api/latest.json?app_id=%s"

	// Application id: https://docs.openexchangerates.org/docs/authentication
	// Using ssm parametor store: https://ap-northeast-1.console.aws.amazon.com/systems-manager/parameters
	svc := ssm.New(sess)
	app_id, err := svc.GetParameter(&ssm.GetParameterInput{
		Name:           aws.String("<YOUR_OPENEXCHANGERATES_APP_ID_PARAMSNAME>"),
		WithDecryption: aws.Bool(true),
	})
	if err != nil {
		log.Println(err.Error())
	}

	// Create Request url
	url := fmt.Sprintf(base, *app_id.Parameter.Value)

	// Start Request
	resp, err := http.Get(url)
	if err != nil {
		log.Println(err.Error())
	}
	defer resp.Body.Close()

	source, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		log.Println(err.Error())
	}

	// Parse json
	desc := Schema{}
	json.Unmarshal(source, &desc)

	return desc.Rates.JPY
}

package main

import (
	"aws-billing-notify/pkg/aws/profile"
	"aws-billing-notify/pkg/aws/sdk/ce/costandusage/calc"
	"aws-billing-notify/pkg/aws/sdk/ce/costandusage/granularity"
	"aws-billing-notify/pkg/aws/sdk/ce/costandusage/group"
	"aws-billing-notify/pkg/aws/sdk/ce/costandusage/metric"
	"aws-billing-notify/pkg/aws/sdk/ce/costandusage/term"
	"fmt"
	"log"
	"strconv"
	"time"

	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/session"
	"github.com/aws/aws-sdk-go/service/costexplorer"
	"github.com/aws/aws-sdk-go/service/costexplorer/costexploreriface"
	"github.com/aws/aws-sdk-go/service/ssm"
)

type costParams struct {
	Granularity *string
	Term        *costexplorer.DateInterval
	Metrics     []*string
	Groups      []*costexplorer.GroupDefinition
}

func (c costParams) getCost(svc costexploreriface.CostExplorerAPI, start *string, end *string) (result *costexplorer.GetCostAndUsageOutput) {
	c.Granularity = granularity.Monthly.String()

	c.Metrics = []*string{
		metric.UnblendedCost.String(),
	}

	c.Term = &costexplorer.DateInterval{
		Start: start,
		End:   end,
	}

	service := costexplorer.GroupDefinition{
		Key:  group.Service.Key(),
		Type: group.Dimention.Type(),
	}
	c.Groups = append(c.Groups, &service)

	input := costexplorer.GetCostAndUsageInput{
		Granularity: c.Granularity,
		TimePeriod:  c.Term,
		Metrics:     c.Metrics,
		GroupBy:     c.Groups,
	}

	result, err := svc.GetCostAndUsage(&input)
	if err != nil {
		log.Println(err.Error())
	}
	return result
}

func main() {
	sess, err := session.NewSessionWithOptions(session.Options{
		SharedConfigState: session.SharedConfigEnable,
		Profile:           profile.Name,
	}) // todo: change lambda
	if err != nil {
		log.Println(err.Error())
	}

	c := costParams{}
	svce := costexplorer.New(sess)
	jst, err := time.LoadLocation("Asia/Tokyo")
	if err != nil {
		log.Println(err.Error())
	}

	start, end := term.CreateThisMonthRange(jst)

	cost := c.getCost(svce, start, end)

	svc := ssm.New(sess)
	rawjpy, err := svc.GetParameter(&ssm.GetParameterInput{
		Name:           aws.String("<YOUR_OPENEXCHANGERATES_JPY_RATE_PARAMSNAME>"),
		WithDecryption: aws.Bool(false),
	})
	if err != nil {
		log.Println(err.Error())
	}

	jpy, err := strconv.ParseFloat(*rawjpy.Parameter.Value, 64)
	if err != nil {
		log.Println(err.Error())
	}

	for _, group := range cost.ResultsByTime[0].Groups {
		amount, err := strconv.ParseFloat(*group.Metrics[*metric.UnblendedCost.String()].Amount, 64)
		if err != nil {
			log.Println(err.Error())
		}
		// Set openexchangerates jpy
		val := fmt.Sprintf("- %s: %f 円", *group.Keys[0], amount*jpy)
		fmt.Println(val)
	}
	// Set openexchangerates jpy
	fmt.Println(calc.Sum(cost, jpy))
}

package main

import (
	"aws-billing-notify/pkg/aws/profile"
	"aws-billing-notify/pkg/openexchangerates"
	"log"

	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/session"
)

func main() {
	sess, err := session.NewSessionWithOptions(session.Options{
		SharedConfigState: session.SharedConfigEnable,
		Profile:           profile.Name,
	})
	if err != nil {
		log.Println(err.Error())
	}
	openexchangerates.PutOpenexchangeratesJpy(sess)
}