r/aws_iot_topic_rule: Add support for 'operation' in DynamoDB action

aws/resource_aws_iot_topic_rule.go

@@ -144,6 +144,11 @@ func resourceAwsIotTopicRule() *schema.Resource {
 							Type:     schema.TypeString,
 							Required: true,
 						},
+						"operation": {
+							Type:         schema.TypeString,
+							Optional:     true,
+							ValidateFunc: validateIoTRuleDynamoDBOperation,
+						},
 					},
 				},
 			},
@@ -402,6 +407,9 @@ func createTopicRulePayload(d *schema.ResourceData) *iot.TopicRulePayload {
 		if v, ok := raw["payload_field"].(string); ok && v != "" {
 			act.DynamoDB.PayloadField = aws.String(v)
 		}
+		if v, ok := raw["operation"].(string); ok && v != "" {
+			act.DynamoDB.Operation = aws.String(v)
+		}
 		actions[i] = act
 		i++
 	}

aws/resource_aws_iot_topic_rule_test.go

@@ -481,7 +481,7 @@ resource "aws_iot_topic_rule" "rule" {
     hash_key_value = "hash_key_value"
     payload_field = "payload_field"
     role_arn = "${aws_iam_role.iot_role.arn}"
-    table_name = "table_name"
+	table_name = "table_name"
   }
 }
 `, rName)
@@ -504,7 +504,8 @@ resource "aws_iot_topic_rule" "rule" {
     range_key_value = "range_key_value"
     range_key_type  = "STRING"
     role_arn = "${aws_iam_role.iot_role.arn}"
-    table_name = "table_name"
+	table_name = "table_name"
+	operation = "INSERT"
   }
 }
 `, rName)

aws/structure.go

@@ -2809,6 +2809,10 @@ func flattenIoTRuleDynamoDbActions(actions []*iot.Action) []map[string]interface
 				m["range_key_value"] = aws.StringValue(v.RangeKeyValue)
 			}
 
+			if v.Operation != nil {
+				m["operation"] = aws.StringValue(v.Operation)
+			}
+
 			items = append(items, m)
 		}
 	}

aws/validators.go

@@ -754,6 +754,18 @@ func validateHTTPMethod() schema.SchemaValidateFunc {
 	}, false)
 }
 
+func validateIoTRuleDynamoDBOperation(v interface{}, k string) (ws []string, errors []error) {
+	value := v.(string)
+	pattern := `^INSERT|UPDATE|DELETE$`
+	if !regexp.MustCompile(pattern).MatchString(value) {
+		errors = append(errors, fmt.Errorf(
+			"%q isn't a valid operation. Use INSERT, UPDATE, or DELETE",
+			k))
+	}
+
+	return
+}
+
 func validateLogMetricFilterName(v interface{}, k string) (ws []string, errors []error) {
 	value := v.(string)
 

website/docs/r/iot_topic_rule.html.markdown

@@ -102,6 +102,7 @@ The `dynamodb` object takes the following arguments:
 * `range_key_field` - (Optional) The range key name.
 * `range_key_type` - (Optional) The range key type. Valid values are "STRING" or "NUMBER".
 * `range_key_value` - (Optional) The range key value.
+* `operation` - (Optional) The operation. Valid values are "INSERT", "UPDATE", or "DELETE".
 * `role_arn` - (Required) The ARN of the IAM role that grants access to the DynamoDB table.
 * `table_name` - (Required) The name of the DynamoDB table.