Add replace field for copy-instance-tags

c7n/resources/ebs.py

@@ -912,7 +912,8 @@ class CopyInstanceTags(BaseAction):
 
     schema = type_schema(
         'copy-instance-tags',
-        tags={'type': 'array', 'items': {'type': 'string'}})
+        tags={'type': 'array', 'items': {'type': 'string'}},
+        replace={'type': 'boolean'})
 
     def get_permissions(self):
         perms = self.manager.get_resource_manager('ec2').get_permissions()
@@ -992,6 +993,7 @@ def process_instance_volumes(self, client, instance, volumes):
     def get_volume_tags(self, volume, instance, attachment):
         only_tags = self.data.get('tags', [])  # specify which tags to copy
         copy_tags = []
+        replace = self.data.get('replace', True)
         extant_tags = dict([
             (t['Key'], t['Value']) for t in volume.get('Tags', [])])
 
@@ -1000,6 +1002,8 @@ def get_volume_tags(self, volume, instance, attachment):
                 continue
             if t['Key'] in extant_tags and t['Value'] == extant_tags[t['Key']]:
                 continue
+            if t['Key'] in extant_tags and not replace:
+                continue
             if t['Key'].startswith('aws:'):
                 continue
             copy_tags.append(t)