Merge pull request #39 from xibz/master

Creating alarms in cloudwatch. Thanks, Ben!

Author: dghale

go/example_code/ec2/create_enable_alarms.go

@@ -0,0 +1,69 @@
+package main
+
+import (
+"fmt"
+"os"
+
+"github.com/aws/aws-sdk-go/aws"
+"github.com/aws/aws-sdk-go/aws/session"
+"github.com/aws/aws-sdk-go/service/cloudwatch"
+)
+
+// Usage:
+// go run main.go <customer id> <instance id> <alarm name>
+func main() {
+// Load session from shared config.
+sess := session.Must(session.NewSessionWithOptions(session.Options{
+SharedConfigState: session.SharedConfigEnable,
+}))
+
+// Create new cloudwatch client.
+svc := cloudwatch.New(sess)
+
+// Create a metric alarm that will reboot an instance if its CPU utilization is
+// greate than 70.0%.
+_, err := svc.PutMetricAlarm(&cloudwatch.PutMetricAlarmInput{
+AlarmName: &os.Args[3],
+ComparisonOperator: aws.String(cloudwatch.ComparisonOperatorGreaterThanThreshold),
+EvaluationPeriods: aws.Int64(1),
+MetricName: aws.String("CPUUtilization"),
+Namespace: aws.String("AWS/EC2"),
+Period: aws.Int64(60),
+Statistic: aws.String(cloudwatch.StatisticAverage),
+Threshold: aws.Float64(70.0),
+ActionsEnabled: aws.Bool(true),
+AlarmDescription: aws.String("Alarm when server CPU exceeds 70%"),
+Unit: aws.String(cloudwatch.StandardUnitSeconds),
+
+// This is apart of the default workflow actions. This one will reboot the instance, if the
+// alarm is triggered.
+AlarmActions: []*string{
+aws.String(fmt.Sprintf("arn:aws:swf:us-east-1:%s:action/actions/AWS_EC2.InstanceId.Reboot/1.0", os.Args[1])),
+},
+Dimensions: []*cloudwatch.Dimension{
+&cloudwatch.Dimension{
+Name: aws.String("InstanceId"),
+Value: &os.Args[2],
+},
+},
+})
+
+if err != nil {
+fmt.Println("Error", err)
+return
+}
+
+// This will enable the alarm to our instance.
+result, err := svc.EnableAlarmActions(&cloudwatch.EnableAlarmActionsInput{
+AlarmNames: []*string{
+&os.Args[3],
+},
+})
+
+if err != nil {
+fmt.Println("Error", err)
+return
+}
+
+fmt.Println("Alarm action enabled", result)
+}

go/example_code/ec2/custom_metrics.go

@@ -0,0 +1,46 @@
+package main
+
+import (
+"fmt"
+
+"github.com/aws/aws-sdk-go/aws"
+"github.com/aws/aws-sdk-go/aws/session"
+"github.com/aws/aws-sdk-go/service/cloudwatch"
+)
+
+// Usage:
+// go run main.go
+func main() {
+// Load session from shared config.
+sess := session.Must(session.NewSessionWithOptions(session.Options{
+SharedConfigState: session.SharedConfigEnable,
+}))
+
+// Create new cloudwatch client.
+svc := cloudwatch.New(sess)
+
+// This will disable the alarm.
+result, err := svc.PutMetricData(&cloudwatch.PutMetricDataInput{
+MetricData: []*cloudwatch.MetricDatum{
+&cloudwatch.MetricDatum{
+MetricName: aws.String("PAGES_VISITED"),
+Unit: aws.String(cloudwatch.StandardUnitNone),
+Value: aws.Float64(1.0),
+Dimensions: []*cloudwatch.Dimension{
+&cloudwatch.Dimension{
+Name: aws.String("UNIQUE_PAGES"),
+Value: aws.String("URLS"),
+},
+},
+},
+},
+Namespace: aws.String("SITE/TRAFFIC"),
+})
+
+if err != nil {
+fmt.Println("Error", err)
+return
+}
+
+fmt.Println("Success", result)
+}

go/example_code/ec2/disable_alarm.go

@@ -0,0 +1,35 @@
+package main
+
+import (
+"fmt"
+"os"
+
+"github.com/aws/aws-sdk-go/aws/session"
+"github.com/aws/aws-sdk-go/service/cloudwatch"
+)
+
+// Usage:
+// go run main.go <alarm name>
+func main() {
+// Load session from shared config.
+sess := session.Must(session.NewSessionWithOptions(session.Options{
+SharedConfigState: session.SharedConfigEnable,
+}))
+
+// Create new cloudwatch client.
+svc := cloudwatch.New(sess)
+
+// This will disable the alarm.
+result, err := svc.DisableAlarmActions(&cloudwatch.DisableAlarmActionsInput{
+AlarmNames: []*string{
+&os.Args[1],
+},
+})
+
+if err != nil {
+fmt.Println("Error", err)
+return
+}
+
+fmt.Println("Success", result)
+}

go/example_code/ec2/listing_metrics.go

@@ -0,0 +1,39 @@
+package main
+
+import (
+"fmt"
+
+"github.com/aws/aws-sdk-go/aws"
+"github.com/aws/aws-sdk-go/aws/session"
+"github.com/aws/aws-sdk-go/service/cloudwatch"
+)
+
+// Usage:
+// go run main.go
+func main() {
+// Load session from shared config.
+sess := session.Must(session.NewSessionWithOptions(session.Options{
+SharedConfigState: session.SharedConfigEnable,
+}))
+
+// Create new cloudwatch client.
+svc := cloudwatch.New(sess)
+
+// This will disable the alarm.
+result, err := svc.ListMetrics(&cloudwatch.ListMetricsInput{
+MetricName: aws.String("IncomingLogEvents"),
+Namespace: aws.String("AWS/Logs"),
+Dimensions: []*cloudwatch.DimensionFilter{
+&cloudwatch.DimensionFilter{
+Name: aws.String("LogGroupName"),
+},
+},
+})
+
+if err != nil {
+fmt.Println("Error", err)
+return
+}
+
+fmt.Println("Metrics", result.Metrics)
+}