Add ec2 instance state reason

- Add instance.reason and instance.state_reason
(http://docs.aws.amazon.com/AWSEC2/latest/APIReference/ApiReference-Item
Type-StateReasonType.html)
- Add ec2 filtering by state-reason-code and state-reason-message
This commit is contained in:
Arthur Wang 2014-10-20 15:54:00 -04:00
commit 6963866c7e
3 changed files with 42 additions and 3 deletions

View file

@ -2,6 +2,7 @@ from __future__ import unicode_literals
import copy
import itertools
from collections import defaultdict
from datetime import datetime
import six
import boto
@ -95,6 +96,11 @@ class InstanceState(object):
self.name = name
self.code = code
class StateReason(object):
def __init__(self, message="", code=""):
self.message = message
self.code = code
class TaggedEC2Resource(object):
def get_tags(self, *args, **kwargs):
@ -258,6 +264,8 @@ class Instance(BotoInstance, TaggedEC2Resource):
self.id = random_instance_id()
self.image_id = image_id
self._state = InstanceState("running", 16)
self._reason = ""
self._state_reason = StateReason()
self.user_data = user_data
self.security_groups = security_groups
self.instance_type = kwargs.get("instance_type", "m1.small")
@ -317,6 +325,9 @@ class Instance(BotoInstance, TaggedEC2Resource):
self._state.name = "running"
self._state.code = 16
self._reason = ""
self._state_reason = StateReason()
def stop(self, *args, **kwargs):
for nic in self.nics.values():
nic.stop()
@ -324,6 +335,10 @@ class Instance(BotoInstance, TaggedEC2Resource):
self._state.name = "stopped"
self._state.code = 80
self._reason = "User initiated ({0})".format(datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S UTC'))
self._state_reason = StateReason("Client.UserInitiatedShutdown: User initiated shutdown",
"Client.UserInitiatedShutdown")
def terminate(self, *args, **kwargs):
for nic in self.nics.values():
nic.stop()
@ -331,10 +346,17 @@ class Instance(BotoInstance, TaggedEC2Resource):
self._state.name = "terminated"
self._state.code = 48
self._reason = "User initiated ({0})".format(datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S UTC'))
self._state_reason = StateReason("Client.UserInitiatedShutdown: User initiated shutdown",
"Client.UserInitiatedShutdown")
def reboot(self, *args, **kwargs):
self._state.name = "running"
self._state.code = 16
self._reason = ""
self._state_reason = StateReason()
def get_tags(self):
tags = ec2_backend.describe_tags(filters={'resource-id': [self.id]})
return tags