services.py 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293
  1. """Services implemented by the AWS provider."""
  2. import ipaddress
  3. import logging
  4. import string
  5. from botocore.exceptions import ClientError
  6. import cachetools
  7. import requests
  8. import cloudbridge.cloud.base.helpers as cb_helpers
  9. from cloudbridge.cloud.base.middleware import dispatch
  10. from cloudbridge.cloud.base.resources import ClientPagedResultList
  11. from cloudbridge.cloud.base.services import BaseBucketObjectService
  12. from cloudbridge.cloud.base.services import BaseBucketService
  13. from cloudbridge.cloud.base.services import BaseComputeService
  14. from cloudbridge.cloud.base.services import BaseFloatingIPService
  15. from cloudbridge.cloud.base.services import BaseGatewayService
  16. from cloudbridge.cloud.base.services import BaseImageService
  17. from cloudbridge.cloud.base.services import BaseInstanceService
  18. from cloudbridge.cloud.base.services import BaseKeyPairService
  19. from cloudbridge.cloud.base.services import BaseNetworkService
  20. from cloudbridge.cloud.base.services import BaseNetworkingService
  21. from cloudbridge.cloud.base.services import BaseRegionService
  22. from cloudbridge.cloud.base.services import BaseRouterService
  23. from cloudbridge.cloud.base.services import BaseSecurityService
  24. from cloudbridge.cloud.base.services import BaseSnapshotService
  25. from cloudbridge.cloud.base.services import BaseStorageService
  26. from cloudbridge.cloud.base.services import BaseSubnetService
  27. from cloudbridge.cloud.base.services import BaseVMFirewallRuleService
  28. from cloudbridge.cloud.base.services import BaseVMFirewallService
  29. from cloudbridge.cloud.base.services import BaseVMTypeService
  30. from cloudbridge.cloud.base.services import BaseVolumeService
  31. from cloudbridge.cloud.interfaces.exceptions import DuplicateResourceException
  32. from cloudbridge.cloud.interfaces.exceptions import \
  33. InvalidConfigurationException
  34. from cloudbridge.cloud.interfaces.exceptions import InvalidParamException
  35. from cloudbridge.cloud.interfaces.exceptions import InvalidValueException
  36. from cloudbridge.cloud.interfaces.resources import KeyPair
  37. from cloudbridge.cloud.interfaces.resources import MachineImage
  38. from cloudbridge.cloud.interfaces.resources import Network
  39. from cloudbridge.cloud.interfaces.resources import PlacementZone
  40. from cloudbridge.cloud.interfaces.resources import Snapshot
  41. from cloudbridge.cloud.interfaces.resources import TrafficDirection
  42. from cloudbridge.cloud.interfaces.resources import VMFirewall
  43. from cloudbridge.cloud.interfaces.resources import VMType
  44. from cloudbridge.cloud.interfaces.resources import Volume
  45. from .helpers import BotoEC2Service
  46. from .helpers import BotoS3Service
  47. from .helpers import trim_empty_params
  48. from .resources import AWSBucket
  49. from .resources import AWSBucketObject
  50. from .resources import AWSFloatingIP
  51. from .resources import AWSInstance
  52. from .resources import AWSInternetGateway
  53. from .resources import AWSKeyPair
  54. from .resources import AWSLaunchConfig
  55. from .resources import AWSMachineImage
  56. from .resources import AWSNetwork
  57. from .resources import AWSPlacementZone
  58. from .resources import AWSRegion
  59. from .resources import AWSRouter
  60. from .resources import AWSSnapshot
  61. from .resources import AWSSubnet
  62. from .resources import AWSVMFirewall
  63. from .resources import AWSVMFirewallRule
  64. from .resources import AWSVMType
  65. from .resources import AWSVolume
  66. log = logging.getLogger(__name__)
  67. class AWSSecurityService(BaseSecurityService):
  68. def __init__(self, provider):
  69. super(AWSSecurityService, self).__init__(provider)
  70. # Initialize provider services
  71. self._key_pairs = AWSKeyPairService(provider)
  72. self._vm_firewalls = AWSVMFirewallService(provider)
  73. self._vm_firewall_rule_svc = AWSVMFirewallRuleService(provider)
  74. @property
  75. def key_pairs(self):
  76. return self._key_pairs
  77. @property
  78. def vm_firewalls(self):
  79. return self._vm_firewalls
  80. @property
  81. def _vm_firewall_rules(self):
  82. return self._vm_firewall_rule_svc
  83. class AWSKeyPairService(BaseKeyPairService):
  84. def __init__(self, provider):
  85. super(AWSKeyPairService, self).__init__(provider)
  86. self.svc = BotoEC2Service(provider=self.provider,
  87. cb_resource=AWSKeyPair,
  88. boto_collection_name='key_pairs')
  89. @dispatch(event="provider.security.key_pairs.get",
  90. priority=BaseKeyPairService.STANDARD_EVENT_PRIORITY)
  91. def get(self, key_pair_id):
  92. log.debug("Getting Key Pair Service %s", key_pair_id)
  93. return self.svc.get(key_pair_id)
  94. @dispatch(event="provider.security.key_pairs.list",
  95. priority=BaseKeyPairService.STANDARD_EVENT_PRIORITY)
  96. def list(self, limit=None, marker=None):
  97. return self.svc.list(limit=limit, marker=marker)
  98. @dispatch(event="provider.security.key_pairs.find",
  99. priority=BaseKeyPairService.STANDARD_EVENT_PRIORITY)
  100. def find(self, **kwargs):
  101. name = kwargs.pop('name', None)
  102. # All kwargs should have been popped at this time.
  103. if len(kwargs) > 0:
  104. raise InvalidParamException(
  105. "Unrecognised parameters for search: %s. Supported "
  106. "attributes: %s" % (kwargs, 'name'))
  107. log.debug("Searching for Key Pair %s", name)
  108. return self.svc.find(filter_name='key-name', filter_value=name)
  109. @dispatch(event="provider.security.key_pairs.create",
  110. priority=BaseKeyPairService.STANDARD_EVENT_PRIORITY)
  111. def create(self, name, public_key_material=None):
  112. AWSKeyPair.assert_valid_resource_name(name)
  113. private_key = None
  114. if not public_key_material:
  115. public_key_material, private_key = cb_helpers.generate_key_pair()
  116. try:
  117. kp = self.svc.create('import_key_pair', KeyName=name,
  118. PublicKeyMaterial=public_key_material)
  119. kp.material = private_key
  120. return kp
  121. except ClientError as e:
  122. if e.response['Error']['Code'] == 'InvalidKeyPair.Duplicate':
  123. raise DuplicateResourceException(
  124. 'Keypair already exists with name {0}'.format(name))
  125. else:
  126. raise e
  127. @dispatch(event="provider.security.key_pairs.delete",
  128. priority=BaseKeyPairService.STANDARD_EVENT_PRIORITY)
  129. def delete(self, key_pair):
  130. key_pair = (key_pair if isinstance(key_pair, AWSKeyPair) else
  131. self.get(key_pair))
  132. if key_pair:
  133. # pylint:disable=protected-access
  134. key_pair._key_pair.delete()
  135. class AWSVMFirewallService(BaseVMFirewallService):
  136. def __init__(self, provider):
  137. super(AWSVMFirewallService, self).__init__(provider)
  138. self.svc = BotoEC2Service(provider=self.provider,
  139. cb_resource=AWSVMFirewall,
  140. boto_collection_name='security_groups')
  141. @dispatch(event="provider.security.vm_firewalls.get",
  142. priority=BaseVMFirewallService.STANDARD_EVENT_PRIORITY)
  143. def get(self, vm_firewall_id):
  144. log.debug("Getting Firewall Service with the id: %s", vm_firewall_id)
  145. return self.svc.get(vm_firewall_id)
  146. @dispatch(event="provider.security.vm_firewalls.list",
  147. priority=BaseVMFirewallService.STANDARD_EVENT_PRIORITY)
  148. def list(self, limit=None, marker=None):
  149. return self.svc.list(limit=limit, marker=marker)
  150. @cb_helpers.deprecated_alias(network_id='network')
  151. @dispatch(event="provider.security.vm_firewalls.create",
  152. priority=BaseVMFirewallService.STANDARD_EVENT_PRIORITY)
  153. def create(self, label, network, description=None):
  154. AWSVMFirewall.assert_valid_resource_label(label)
  155. name = AWSVMFirewall._generate_name_from_label(label, 'cb-fw')
  156. network_id = network.id if isinstance(network, Network) else network
  157. obj = self.svc.create('create_security_group', GroupName=name,
  158. Description=description or name,
  159. VpcId=network_id)
  160. obj.label = label
  161. return obj
  162. @dispatch(event="provider.security.vm_firewalls.find",
  163. priority=BaseVMFirewallService.STANDARD_EVENT_PRIORITY)
  164. def find(self, **kwargs):
  165. # Filter by name or label
  166. label = kwargs.pop('label', None)
  167. log.debug("Searching for Firewall Service %s", label)
  168. # All kwargs should have been popped at this time.
  169. if len(kwargs) > 0:
  170. raise InvalidParamException(
  171. "Unrecognised parameters for search: %s. Supported "
  172. "attributes: %s" % (kwargs, 'label'))
  173. return self.svc.find(filter_name='tag:Name',
  174. filter_value=label)
  175. @dispatch(event="provider.security.vm_firewalls.delete",
  176. priority=BaseVMFirewallService.STANDARD_EVENT_PRIORITY)
  177. def delete(self, vm_firewall):
  178. firewall = (vm_firewall if isinstance(vm_firewall, AWSVMFirewall)
  179. else self.get(vm_firewall))
  180. if firewall:
  181. # pylint:disable=protected-access
  182. firewall._vm_firewall.delete()
  183. class AWSVMFirewallRuleService(BaseVMFirewallRuleService):
  184. def __init__(self, provider):
  185. super(AWSVMFirewallRuleService, self).__init__(provider)
  186. @dispatch(event="provider.security.vm_firewall_rules.list",
  187. priority=BaseVMFirewallRuleService.STANDARD_EVENT_PRIORITY)
  188. def list(self, firewall, limit=None, marker=None):
  189. # pylint:disable=protected-access
  190. rules = [AWSVMFirewallRule(firewall,
  191. TrafficDirection.INBOUND, r)
  192. for r in firewall._vm_firewall.ip_permissions]
  193. # pylint:disable=protected-access
  194. rules = rules + [
  195. AWSVMFirewallRule(
  196. firewall, TrafficDirection.OUTBOUND, r)
  197. for r in firewall._vm_firewall.ip_permissions_egress]
  198. return ClientPagedResultList(self.provider, rules,
  199. limit=limit, marker=marker)
  200. @dispatch(event="provider.security.vm_firewall_rules.create",
  201. priority=BaseVMFirewallRuleService.STANDARD_EVENT_PRIORITY)
  202. def create(self, firewall, direction, protocol=None, from_port=None,
  203. to_port=None, cidr=None, src_dest_fw=None):
  204. src_dest_fw_id = (
  205. src_dest_fw.id if isinstance(src_dest_fw, AWSVMFirewall)
  206. else src_dest_fw)
  207. # pylint:disable=protected-access
  208. ip_perm_entry = AWSVMFirewallRule._construct_ip_perms(
  209. protocol, from_port, to_port, cidr, src_dest_fw_id)
  210. # Filter out empty values to please Boto
  211. ip_perms = [trim_empty_params(ip_perm_entry)]
  212. try:
  213. if direction == TrafficDirection.INBOUND:
  214. # pylint:disable=protected-access
  215. firewall._vm_firewall.authorize_ingress(
  216. IpPermissions=ip_perms)
  217. elif direction == TrafficDirection.OUTBOUND:
  218. # pylint:disable=protected-access
  219. firewall._vm_firewall.authorize_egress(
  220. IpPermissions=ip_perms)
  221. else:
  222. raise InvalidValueException("direction", direction)
  223. firewall.refresh()
  224. return AWSVMFirewallRule(firewall, direction, ip_perm_entry)
  225. except ClientError as ec2e:
  226. if ec2e.response['Error']['Code'] == "InvalidPermission.Duplicate":
  227. return AWSVMFirewallRule(
  228. firewall, direction, ip_perm_entry)
  229. else:
  230. raise ec2e
  231. @dispatch(event="provider.security.vm_firewall_rules.delete",
  232. priority=BaseVMFirewallRuleService.STANDARD_EVENT_PRIORITY)
  233. def delete(self, firewall, rule):
  234. # pylint:disable=protected-access
  235. ip_perm_entry = rule._construct_ip_perms(
  236. rule.protocol, rule.from_port, rule.to_port,
  237. rule.cidr, rule.src_dest_fw_id)
  238. # Filter out empty values to please Boto
  239. ip_perms = [trim_empty_params(ip_perm_entry)]
  240. # pylint:disable=protected-access
  241. if rule.direction == TrafficDirection.INBOUND:
  242. firewall._vm_firewall.revoke_ingress(
  243. IpPermissions=ip_perms)
  244. else:
  245. # pylint:disable=protected-access
  246. firewall._vm_firewall.revoke_egress(
  247. IpPermissions=ip_perms)
  248. firewall.refresh()
  249. class AWSStorageService(BaseStorageService):
  250. def __init__(self, provider):
  251. super(AWSStorageService, self).__init__(provider)
  252. # Initialize provider services
  253. self._volume_svc = AWSVolumeService(self.provider)
  254. self._snapshot_svc = AWSSnapshotService(self.provider)
  255. self._bucket_svc = AWSBucketService(self.provider)
  256. self._bucket_obj_svc = AWSBucketObjectService(self.provider)
  257. @property
  258. def volumes(self):
  259. return self._volume_svc
  260. @property
  261. def snapshots(self):
  262. return self._snapshot_svc
  263. @property
  264. def buckets(self):
  265. return self._bucket_svc
  266. @property
  267. def _bucket_objects(self):
  268. return self._bucket_obj_svc
  269. class AWSVolumeService(BaseVolumeService):
  270. def __init__(self, provider):
  271. super(AWSVolumeService, self).__init__(provider)
  272. self.svc = BotoEC2Service(provider=self.provider,
  273. cb_resource=AWSVolume,
  274. boto_collection_name='volumes')
  275. @dispatch(event="provider.storage.volumes.get",
  276. priority=BaseVolumeService.STANDARD_EVENT_PRIORITY)
  277. def get(self, volume_id):
  278. return self.svc.get(volume_id)
  279. @dispatch(event="provider.storage.volumes.find",
  280. priority=BaseVolumeService.STANDARD_EVENT_PRIORITY)
  281. def find(self, **kwargs):
  282. label = kwargs.pop('label', None)
  283. # All kwargs should have been popped at this time.
  284. if len(kwargs) > 0:
  285. raise InvalidParamException(
  286. "Unrecognised parameters for search: %s. Supported "
  287. "attributes: %s" % (kwargs, 'label'))
  288. log.debug("Searching for AWS Volume Service %s", label)
  289. return self.svc.find(filter_name='tag:Name', filter_value=label)
  290. @dispatch(event="provider.storage.volumes.list",
  291. priority=BaseVolumeService.STANDARD_EVENT_PRIORITY)
  292. def list(self, limit=None, marker=None):
  293. return self.svc.list(limit=limit, marker=marker)
  294. @dispatch(event="provider.storage.volumes.create",
  295. priority=BaseVolumeService.STANDARD_EVENT_PRIORITY)
  296. def create(self, label, size, zone, snapshot=None, description=None):
  297. AWSVolume.assert_valid_resource_label(label)
  298. zone_id = zone.id if isinstance(zone, PlacementZone) else zone
  299. snapshot_id = snapshot.id if isinstance(
  300. snapshot, AWSSnapshot) and snapshot else snapshot
  301. cb_vol = self.svc.create('create_volume', Size=size,
  302. AvailabilityZone=zone_id,
  303. SnapshotId=snapshot_id)
  304. # Wait until ready to tag instance
  305. cb_vol.wait_till_ready()
  306. cb_vol.label = label
  307. if description:
  308. cb_vol.description = description
  309. return cb_vol
  310. @dispatch(event="provider.storage.volumes.delete",
  311. priority=BaseVolumeService.STANDARD_EVENT_PRIORITY)
  312. def delete(self, vol):
  313. volume = vol if isinstance(vol, AWSVolume) else self.get(vol)
  314. if volume:
  315. # pylint:disable=protected-access
  316. volume._volume.delete()
  317. class AWSSnapshotService(BaseSnapshotService):
  318. def __init__(self, provider):
  319. super(AWSSnapshotService, self).__init__(provider)
  320. self.svc = BotoEC2Service(provider=self.provider,
  321. cb_resource=AWSSnapshot,
  322. boto_collection_name='snapshots')
  323. @dispatch(event="provider.storage.snapshots.get",
  324. priority=BaseSnapshotService.STANDARD_EVENT_PRIORITY)
  325. def get(self, snapshot_id):
  326. return self.svc.get(snapshot_id)
  327. @dispatch(event="provider.storage.snapshots.find",
  328. priority=BaseSnapshotService.STANDARD_EVENT_PRIORITY)
  329. def find(self, **kwargs):
  330. # Filter by description or label
  331. label = kwargs.get('label', None)
  332. obj_list = []
  333. if label:
  334. log.debug("Searching for AWS Snapshot with label %s", label)
  335. obj_list.extend(self.svc.find(filter_name='tag:Name',
  336. filter_value=label,
  337. OwnerIds=['self']))
  338. else:
  339. obj_list = list(self)
  340. filters = ['label']
  341. return cb_helpers.generic_find(filters, kwargs, obj_list)
  342. @dispatch(event="provider.storage.snapshots.list",
  343. priority=BaseSnapshotService.STANDARD_EVENT_PRIORITY)
  344. def list(self, limit=None, marker=None):
  345. return self.svc.list(limit=limit, marker=marker,
  346. OwnerIds=['self'])
  347. @dispatch(event="provider.storage.snapshots.create",
  348. priority=BaseSnapshotService.STANDARD_EVENT_PRIORITY)
  349. def create(self, label, volume, description=None):
  350. AWSSnapshot.assert_valid_resource_label(label)
  351. volume_id = volume.id if isinstance(volume, AWSVolume) else volume
  352. cb_snap = self.svc.create('create_snapshot', VolumeId=volume_id)
  353. # Wait until ready to tag instance
  354. cb_snap.wait_till_ready()
  355. cb_snap.label = label
  356. if cb_snap.description:
  357. cb_snap.description = description
  358. return cb_snap
  359. @dispatch(event="provider.storage.snapshots.delete",
  360. priority=BaseSnapshotService.STANDARD_EVENT_PRIORITY)
  361. def delete(self, snapshot):
  362. snapshot = (snapshot if isinstance(snapshot, AWSSnapshot) else
  363. self.get(snapshot))
  364. if snapshot:
  365. # pylint:disable=protected-access
  366. snapshot._snapshot.delete()
  367. class AWSBucketService(BaseBucketService):
  368. def __init__(self, provider):
  369. super(AWSBucketService, self).__init__(provider)
  370. self.svc = BotoS3Service(provider=self.provider,
  371. cb_resource=AWSBucket,
  372. boto_collection_name='buckets')
  373. @dispatch(event="provider.storage.buckets.get",
  374. priority=BaseBucketService.STANDARD_EVENT_PRIORITY)
  375. def get(self, bucket_id):
  376. """
  377. Returns a bucket given its ID. Returns ``None`` if the bucket
  378. does not exist.
  379. """
  380. try:
  381. # Make a call to make sure the bucket exists. There's an edge case
  382. # where a 403 response can occur when the bucket exists but the
  383. # user simply does not have permissions to access it. See below.
  384. self.provider.s3_conn.meta.client.head_bucket(Bucket=bucket_id)
  385. return AWSBucket(self.provider,
  386. self.provider.s3_conn.Bucket(bucket_id))
  387. except ClientError as e:
  388. # If 403, it means the bucket exists, but the user does not have
  389. # permissions to access the bucket. However, limited operations
  390. # may be permitted (with a session token for example), so return a
  391. # Bucket instance to allow further operations.
  392. # http://stackoverflow.com/questions/32331456/using-boto-upload-file-to-s3-
  393. # sub-folder-when-i-have-no-permissions-on-listing-fo
  394. if e.response['Error']['Code'] == "403":
  395. log.warning("AWS Bucket %s already exists but user doesn't "
  396. "have enough permissions to access the bucket",
  397. bucket_id)
  398. return AWSBucket(self.provider,
  399. self.provider.s3_conn.Bucket(bucket_id))
  400. # For all other responses, it's assumed that the bucket does not exist.
  401. return None
  402. @dispatch(event="provider.storage.buckets.list",
  403. priority=BaseBucketService.STANDARD_EVENT_PRIORITY)
  404. def list(self, limit=None, marker=None):
  405. return self.svc.list(limit=limit, marker=marker)
  406. @dispatch(event="provider.storage.buckets.create",
  407. priority=BaseBucketService.STANDARD_EVENT_PRIORITY)
  408. def create(self, name, location=None):
  409. AWSBucket.assert_valid_resource_name(name)
  410. location = location or self.provider.region_name
  411. # Due to an API issue in S3, specifying us-east-1 as a
  412. # LocationConstraint results in an InvalidLocationConstraint.
  413. # Therefore, it must be special-cased and omitted altogether.
  414. # See: https://github.com/boto/boto3/issues/125
  415. # In addition, us-east-1 also behaves differently when it comes
  416. # to raising duplicate resource exceptions, so perform a manual
  417. # check
  418. if location == 'us-east-1':
  419. try:
  420. # check whether bucket already exists
  421. self.provider.s3_conn.meta.client.head_bucket(Bucket=name)
  422. except ClientError as e:
  423. if e.response['Error']['Code'] == "404":
  424. # bucket doesn't exist, go ahead and create it
  425. return self.svc.create('create_bucket', Bucket=name)
  426. raise DuplicateResourceException(
  427. 'Bucket already exists with name {0}'.format(name))
  428. else:
  429. try:
  430. return self.svc.create('create_bucket', Bucket=name,
  431. CreateBucketConfiguration={
  432. 'LocationConstraint': location
  433. })
  434. except ClientError as e:
  435. if e.response['Error']['Code'] == "BucketAlreadyOwnedByYou":
  436. raise DuplicateResourceException(
  437. 'Bucket already exists with name {0}'.format(name))
  438. else:
  439. raise
  440. @dispatch(event="provider.storage.buckets.delete",
  441. priority=BaseBucketService.STANDARD_EVENT_PRIORITY)
  442. def delete(self, bucket):
  443. b = bucket if isinstance(bucket, AWSBucket) else self.get(bucket)
  444. if b:
  445. # pylint:disable=protected-access
  446. b._bucket.delete()
  447. class AWSBucketObjectService(BaseBucketObjectService):
  448. def __init__(self, provider):
  449. super(AWSBucketObjectService, self).__init__(provider)
  450. def get(self, bucket, object_id):
  451. try:
  452. # pylint:disable=protected-access
  453. obj = bucket._bucket.Object(object_id)
  454. # load() throws an error if object does not exist
  455. obj.load()
  456. return AWSBucketObject(self.provider, obj)
  457. except ClientError:
  458. return None
  459. def list(self, bucket, limit=None, marker=None, prefix=None):
  460. if prefix:
  461. # pylint:disable=protected-access
  462. boto_objs = bucket._bucket.objects.filter(Prefix=prefix)
  463. else:
  464. # pylint:disable=protected-access
  465. boto_objs = bucket._bucket.objects.all()
  466. objects = [AWSBucketObject(self.provider, obj) for obj in boto_objs]
  467. return ClientPagedResultList(self.provider, objects,
  468. limit=limit, marker=marker)
  469. def find(self, bucket, **kwargs):
  470. # pylint:disable=protected-access
  471. obj_list = [AWSBucketObject(self.provider, o)
  472. for o in bucket._bucket.objects.all()]
  473. filters = ['name']
  474. matches = cb_helpers.generic_find(filters, kwargs, obj_list)
  475. return ClientPagedResultList(self.provider, list(matches),
  476. limit=None, marker=None)
  477. def create(self, bucket, name):
  478. # pylint:disable=protected-access
  479. obj = bucket._bucket.Object(name)
  480. return AWSBucketObject(self.provider, obj)
  481. class AWSComputeService(BaseComputeService):
  482. def __init__(self, provider):
  483. super(AWSComputeService, self).__init__(provider)
  484. self._vm_type_svc = AWSVMTypeService(self.provider)
  485. self._instance_svc = AWSInstanceService(self.provider)
  486. self._region_svc = AWSRegionService(self.provider)
  487. self._images_svc = AWSImageService(self.provider)
  488. @property
  489. def images(self):
  490. return self._images_svc
  491. @property
  492. def vm_types(self):
  493. return self._vm_type_svc
  494. @property
  495. def instances(self):
  496. return self._instance_svc
  497. @property
  498. def regions(self):
  499. return self._region_svc
  500. class AWSImageService(BaseImageService):
  501. def __init__(self, provider):
  502. super(AWSImageService, self).__init__(provider)
  503. self.svc = BotoEC2Service(provider=self.provider,
  504. cb_resource=AWSMachineImage,
  505. boto_collection_name='images')
  506. def get(self, image_id):
  507. log.debug("Getting AWS Image Service with the id: %s", image_id)
  508. return self.svc.get(image_id)
  509. def find(self, **kwargs):
  510. # Filter by name or label
  511. label = kwargs.pop('label', None)
  512. # Popped here, not used in the generic find
  513. owner = kwargs.pop('owners', None)
  514. # All kwargs should have been popped at this time.
  515. if len(kwargs) > 0:
  516. raise InvalidParamException(
  517. "Unrecognised parameters for search: %s. Supported "
  518. "attributes: %s" % (kwargs, 'label'))
  519. extra_args = {}
  520. if owner:
  521. extra_args.update(Owners=owner)
  522. # The original list is made by combining both searches by "tag:Name"
  523. # and "AMI name" to allow for searches of public images
  524. if label:
  525. log.debug("Searching for AWS Image Service %s", label)
  526. obj_list = []
  527. obj_list.extend(self.svc.find(filter_name='name',
  528. filter_value=label, **extra_args))
  529. obj_list.extend(self.svc.find(filter_name='tag:Name',
  530. filter_value=label, **extra_args))
  531. return obj_list
  532. else:
  533. return []
  534. def list(self, filter_by_owner=True, limit=None, marker=None):
  535. return self.svc.list(Owners=['self'] if filter_by_owner else
  536. ['amazon', 'self'],
  537. limit=limit, marker=marker)
  538. class AWSInstanceService(BaseInstanceService):
  539. def __init__(self, provider):
  540. super(AWSInstanceService, self).__init__(provider)
  541. self.svc = BotoEC2Service(provider=self.provider,
  542. cb_resource=AWSInstance,
  543. boto_collection_name='instances')
  544. def _resolve_launch_options(self, subnet=None, zone_id=None,
  545. vm_firewalls=None):
  546. """
  547. Work out interdependent launch options.
  548. Some launch options are required and interdependent so make sure
  549. they conform to the interface contract.
  550. :type subnet: ``Subnet``
  551. :param subnet: Subnet object within which to launch.
  552. :type zone_id: ``str``
  553. :param zone_id: ID of the zone where the launch should happen.
  554. :type vm_firewalls: ``list`` of ``id``
  555. :param vm_firewalls: List of firewall IDs.
  556. :rtype: triplet of ``str``
  557. :return: Subnet ID, zone ID and VM firewall IDs for launch.
  558. :raise ValueError: In case a conflicting combination is found.
  559. """
  560. if subnet:
  561. # subnet's zone takes precedence
  562. zone_id = subnet.zone.id
  563. if isinstance(vm_firewalls, list) and isinstance(
  564. vm_firewalls[0], VMFirewall):
  565. vm_firewall_ids = [fw.id for fw in vm_firewalls]
  566. else:
  567. vm_firewall_ids = vm_firewalls
  568. return subnet.id, zone_id, vm_firewall_ids
  569. def _process_block_device_mappings(self, launch_config):
  570. """
  571. Processes block device mapping information
  572. and returns a Boto BlockDeviceMapping object. If new volumes
  573. are requested (source is None and destination is VOLUME), they will be
  574. created and the relevant volume ids included in the mapping.
  575. """
  576. bdml = []
  577. # Assign letters from f onwards
  578. # http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/device_naming.html
  579. next_letter = iter(list(string.ascii_lowercase[6:]))
  580. # assign ephemeral devices from 0 onwards
  581. ephemeral_counter = 0
  582. for device in launch_config.block_devices:
  583. bdm = {}
  584. if device.is_volume:
  585. # Generate the device path
  586. bdm['DeviceName'] = \
  587. '/dev/sd' + ('a1' if device.is_root else next(next_letter))
  588. ebs_def = {}
  589. if isinstance(device.source, Snapshot):
  590. ebs_def['SnapshotId'] = device.source.id
  591. elif isinstance(device.source, Volume):
  592. # TODO: We could create a snapshot from the volume
  593. # and use that instead.
  594. # Not supported
  595. pass
  596. elif isinstance(device.source, MachineImage):
  597. # Not supported
  598. pass
  599. else:
  600. # source is None, but destination is volume, therefore
  601. # create a blank volume. This requires a size though.
  602. if not device.size:
  603. raise InvalidConfigurationException(
  604. "The source is none and the destination is a"
  605. " volume. Therefore, you must specify a size.")
  606. ebs_def['DeleteOnTermination'] = device.delete_on_terminate \
  607. or True
  608. if device.size:
  609. ebs_def['VolumeSize'] = device.size
  610. if ebs_def:
  611. bdm['Ebs'] = ebs_def
  612. else: # device is ephemeral
  613. bdm['VirtualName'] = 'ephemeral%s' % ephemeral_counter
  614. # Append the config
  615. bdml.append(bdm)
  616. return bdml
  617. def create_launch_config(self):
  618. return AWSLaunchConfig(self.provider)
  619. @dispatch(event="provider.compute.instances.create",
  620. priority=BaseInstanceService.STANDARD_EVENT_PRIORITY)
  621. def create(self, label, image, vm_type, subnet, zone,
  622. key_pair=None, vm_firewalls=None, user_data=None,
  623. launch_config=None, **kwargs):
  624. AWSInstance.assert_valid_resource_label(label)
  625. image_id = image.id if isinstance(image, MachineImage) else image
  626. vm_size = vm_type.id if \
  627. isinstance(vm_type, VMType) else vm_type
  628. subnet = (self.provider.networking.subnets.get(subnet)
  629. if isinstance(subnet, str) else subnet)
  630. zone_id = zone.id if isinstance(zone, PlacementZone) else zone
  631. key_pair_name = key_pair.name if isinstance(
  632. key_pair,
  633. KeyPair) else key_pair
  634. if launch_config:
  635. bdm = self._process_block_device_mappings(launch_config)
  636. else:
  637. bdm = None
  638. subnet_id, zone_id, vm_firewall_ids = \
  639. self._resolve_launch_options(subnet, zone_id, vm_firewalls)
  640. placement = {'AvailabilityZone': zone_id} if zone_id else None
  641. inst = self.svc.create('create_instances',
  642. ImageId=image_id,
  643. MinCount=1,
  644. MaxCount=1,
  645. KeyName=key_pair_name,
  646. SecurityGroupIds=vm_firewall_ids or None,
  647. UserData=str(user_data) or None,
  648. InstanceType=vm_size,
  649. Placement=placement,
  650. BlockDeviceMappings=bdm,
  651. SubnetId=subnet_id
  652. )
  653. if inst and len(inst) == 1:
  654. # Wait until the resource exists
  655. # pylint:disable=protected-access
  656. inst[0]._wait_till_exists()
  657. # Tag the instance w/ the name
  658. inst[0].label = label
  659. return inst[0]
  660. raise ValueError(
  661. 'Expected a single object response, got a list: %s' % inst)
  662. @dispatch(event="provider.compute.instances.get",
  663. priority=BaseInstanceService.STANDARD_EVENT_PRIORITY)
  664. def get(self, instance_id):
  665. return self.svc.get(instance_id)
  666. @dispatch(event="provider.compute.instances.find",
  667. priority=BaseInstanceService.STANDARD_EVENT_PRIORITY)
  668. def find(self, **kwargs):
  669. label = kwargs.pop('label', None)
  670. # All kwargs should have been popped at this time.
  671. if len(kwargs) > 0:
  672. raise InvalidParamException(
  673. "Unrecognised parameters for search: %s. Supported "
  674. "attributes: %s" % (kwargs, 'label'))
  675. return self.svc.find(filter_name='tag:Name', filter_value=label)
  676. @dispatch(event="provider.compute.instances.list",
  677. priority=BaseInstanceService.STANDARD_EVENT_PRIORITY)
  678. def list(self, limit=None, marker=None):
  679. return self.svc.list(limit=limit, marker=marker)
  680. @dispatch(event="provider.compute.instances.delete",
  681. priority=BaseInstanceService.STANDARD_EVENT_PRIORITY)
  682. def delete(self, instance):
  683. aws_inst = (instance if isinstance(instance, AWSInstance) else
  684. self.get(instance))
  685. if aws_inst:
  686. # pylint:disable=protected-access
  687. aws_inst._ec2_instance.terminate()
  688. class AWSVMTypeService(BaseVMTypeService):
  689. def __init__(self, provider):
  690. super(AWSVMTypeService, self).__init__(provider)
  691. @property
  692. @cachetools.cached(cachetools.TTLCache(maxsize=1, ttl=24*3600))
  693. def instance_data(self):
  694. """
  695. Fetch info about the available instances.
  696. To update this information, update the file pointed to by the
  697. ``provider.AWS_INSTANCE_DATA_DEFAULT_URL`` above. The content for this
  698. file should be obtained from this repo:
  699. https://github.com/powdahound/ec2instances.info (in particular, this
  700. file: https://raw.githubusercontent.com/powdahound/ec2instances.info/
  701. master/www/instances.json).
  702. """
  703. r = requests.get(self.provider.config.get(
  704. "aws_instance_info_url",
  705. self.provider.AWS_INSTANCE_DATA_DEFAULT_URL))
  706. # Some instances are only available in certain regions. Use pricing
  707. # info to determine and filter out instance types that are not
  708. # available in the current region
  709. vm_types_list = r.json()
  710. return [vm_type for vm_type in vm_types_list
  711. if vm_type.get('pricing', {}).get(self.provider.region_name)]
  712. @dispatch(event="provider.compute.vm_types.list",
  713. priority=BaseVMTypeService.STANDARD_EVENT_PRIORITY)
  714. def list(self, limit=None, marker=None):
  715. vm_types = [AWSVMType(self.provider, vm_type)
  716. for vm_type in self.instance_data]
  717. return ClientPagedResultList(self.provider, vm_types,
  718. limit=limit, marker=marker)
  719. class AWSRegionService(BaseRegionService):
  720. def __init__(self, provider):
  721. super(AWSRegionService, self).__init__(provider)
  722. @dispatch(event="provider.compute.regions.get",
  723. priority=BaseRegionService.STANDARD_EVENT_PRIORITY)
  724. def get(self, region_id):
  725. log.debug("Getting AWS Region Service with the id: %s",
  726. region_id)
  727. region = [r for r in self if r.id == region_id]
  728. if region:
  729. return region[0]
  730. else:
  731. return None
  732. @dispatch(event="provider.compute.regions.list",
  733. priority=BaseRegionService.STANDARD_EVENT_PRIORITY)
  734. def list(self, limit=None, marker=None):
  735. regions = [
  736. AWSRegion(self.provider, region) for region in
  737. self.provider.ec2_conn.meta.client.describe_regions()
  738. .get('Regions', [])]
  739. return ClientPagedResultList(self.provider, regions,
  740. limit=limit, marker=marker)
  741. @property
  742. def current(self):
  743. return self.get(self._provider.region_name)
  744. class AWSNetworkingService(BaseNetworkingService):
  745. def __init__(self, provider):
  746. super(AWSNetworkingService, self).__init__(provider)
  747. self._network_service = AWSNetworkService(self.provider)
  748. self._subnet_service = AWSSubnetService(self.provider)
  749. self._router_service = AWSRouterService(self.provider)
  750. self._gateway_service = AWSGatewayService(self.provider)
  751. self._floating_ip_service = AWSFloatingIPService(self.provider)
  752. @property
  753. def networks(self):
  754. return self._network_service
  755. @property
  756. def subnets(self):
  757. return self._subnet_service
  758. @property
  759. def routers(self):
  760. return self._router_service
  761. @property
  762. def _gateways(self):
  763. return self._gateway_service
  764. @property
  765. def _floating_ips(self):
  766. return self._floating_ip_service
  767. class AWSNetworkService(BaseNetworkService):
  768. def __init__(self, provider):
  769. super(AWSNetworkService, self).__init__(provider)
  770. self.svc = BotoEC2Service(provider=self.provider,
  771. cb_resource=AWSNetwork,
  772. boto_collection_name='vpcs')
  773. @dispatch(event="provider.networking.networks.get",
  774. priority=BaseNetworkService.STANDARD_EVENT_PRIORITY)
  775. def get(self, network_id):
  776. return self.svc.get(network_id)
  777. @dispatch(event="provider.networking.networks.list",
  778. priority=BaseNetworkService.STANDARD_EVENT_PRIORITY)
  779. def list(self, limit=None, marker=None):
  780. return self.svc.list(limit=limit, marker=marker)
  781. @dispatch(event="provider.networking.networks.find",
  782. priority=BaseNetworkService.STANDARD_EVENT_PRIORITY)
  783. def find(self, **kwargs):
  784. label = kwargs.pop('label', None)
  785. # All kwargs should have been popped at this time.
  786. if len(kwargs) > 0:
  787. raise InvalidParamException(
  788. "Unrecognised parameters for search: %s. Supported "
  789. "attributes: %s" % (kwargs, 'label'))
  790. log.debug("Searching for AWS Network Service %s", label)
  791. return self.svc.find(filter_name='tag:Name', filter_value=label)
  792. @dispatch(event="provider.networking.networks.create",
  793. priority=BaseNetworkService.STANDARD_EVENT_PRIORITY)
  794. def create(self, label, cidr_block):
  795. AWSNetwork.assert_valid_resource_label(label)
  796. cb_net = self.svc.create('create_vpc', CidrBlock=cidr_block)
  797. # Wait until ready to tag instance
  798. cb_net.wait_till_ready()
  799. if label:
  800. cb_net.label = label
  801. return cb_net
  802. @dispatch(event="provider.networking.networks.delete",
  803. priority=BaseNetworkService.STANDARD_EVENT_PRIORITY)
  804. def delete(self, network):
  805. network = (network if isinstance(network, AWSNetwork)
  806. else self.get(network))
  807. if network:
  808. # pylint:disable=protected-access
  809. network._vpc.delete()
  810. def get_or_create_default(self):
  811. # # Look for provided default network
  812. # for net in self.provider.networking.networks:
  813. # pylint:disable=protected-access
  814. # if net._vpc.is_default:
  815. # return net
  816. # No provider-default, try CB-default instead
  817. default_nets = self.provider.networking.networks.find(
  818. label=AWSNetwork.CB_DEFAULT_NETWORK_LABEL)
  819. if default_nets:
  820. return default_nets[0]
  821. else:
  822. log.info("Creating a CloudBridge-default network labeled %s",
  823. AWSNetwork.CB_DEFAULT_NETWORK_LABEL)
  824. return self.provider.networking.networks.create(
  825. label=AWSNetwork.CB_DEFAULT_NETWORK_LABEL,
  826. cidr_block=AWSNetwork.CB_DEFAULT_IPV4RANGE)
  827. class AWSSubnetService(BaseSubnetService):
  828. def __init__(self, provider):
  829. super(AWSSubnetService, self).__init__(provider)
  830. self.svc = BotoEC2Service(provider=self.provider,
  831. cb_resource=AWSSubnet,
  832. boto_collection_name='subnets')
  833. @dispatch(event="provider.networking.subnets.get",
  834. priority=BaseSubnetService.STANDARD_EVENT_PRIORITY)
  835. def get(self, subnet_id):
  836. return self.svc.get(subnet_id)
  837. @dispatch(event="provider.networking.subnets.list",
  838. priority=BaseSubnetService.STANDARD_EVENT_PRIORITY)
  839. def list(self, network=None, limit=None, marker=None):
  840. network_id = network.id if isinstance(network, AWSNetwork) else network
  841. if network_id:
  842. return self.svc.find(
  843. filter_name='vpc-id', filter_value=network_id,
  844. limit=limit, marker=marker)
  845. else:
  846. return self.svc.list(limit=limit, marker=marker)
  847. @dispatch(event="provider.networking.subnets.find",
  848. priority=BaseSubnetService.STANDARD_EVENT_PRIORITY)
  849. def find(self, network=None, **kwargs):
  850. label = kwargs.pop('label', None)
  851. # All kwargs should have been popped at this time.
  852. if len(kwargs) > 0:
  853. raise InvalidParamException(
  854. "Unrecognised parameters for search: %s. Supported "
  855. "attributes: %s" % (kwargs, 'label'))
  856. log.debug("Searching for AWS Subnet Service %s", label)
  857. return self.svc.find(filter_name='tag:Name', filter_value=label)
  858. @dispatch(event="provider.networking.subnets.create",
  859. priority=BaseSubnetService.STANDARD_EVENT_PRIORITY)
  860. def create(self, label, network, cidr_block, zone):
  861. AWSSubnet.assert_valid_resource_label(label)
  862. zone_name = zone.name if isinstance(
  863. zone, AWSPlacementZone) else zone
  864. network_id = network.id if isinstance(network, AWSNetwork) else network
  865. subnet = self.svc.create('create_subnet',
  866. VpcId=network_id,
  867. CidrBlock=cidr_block,
  868. AvailabilityZone=zone_name)
  869. if label:
  870. subnet.label = label
  871. return subnet
  872. @dispatch(event="provider.networking.subnets.delete",
  873. priority=BaseSubnetService.STANDARD_EVENT_PRIORITY)
  874. def delete(self, subnet):
  875. sn = subnet if isinstance(subnet, AWSSubnet) else self.get(subnet)
  876. if sn:
  877. # pylint:disable=protected-access
  878. sn._subnet.delete()
  879. def get_or_create_default(self, zone):
  880. zone_name = zone.name if isinstance(zone, AWSPlacementZone) else zone
  881. # # Look for provider default subnet in current zone
  882. # if zone_name:
  883. # snl = self.svc.find('availabilityZone', zone_name)
  884. #
  885. # else:
  886. # snl = self.svc.list()
  887. # # Find first available default subnet by sorted order
  888. # # of availability zone. Prefer zone us-east-1a over 1e,
  889. # # because newer zones tend to have less compatibility
  890. # # with different instance types (e.g. c5.large not available
  891. # # on us-east-1e as of 14 Dec. 2017).
  892. # # pylint:disable=protected-access
  893. # snl.sort(key=lambda sn: sn._subnet.availability_zone)
  894. #
  895. # for sn in snl:
  896. # # pylint:disable=protected-access
  897. # if sn._subnet.default_for_az:
  898. # return sn
  899. # If no provider-default subnet has been found, look for
  900. # cloudbridge-default by label. We suffix labels by availability zone,
  901. # thus we add the wildcard for the regular expression to find the
  902. # subnet
  903. snl = self.find(label=AWSSubnet.CB_DEFAULT_SUBNET_LABEL + "*")
  904. if snl:
  905. # pylint:disable=protected-access
  906. snl.sort(key=lambda sn: sn._subnet.availability_zone)
  907. if not zone_name:
  908. return snl[0]
  909. for subnet in snl:
  910. if subnet.zone.name == zone_name:
  911. return subnet
  912. # No default Subnet exists, try to create a CloudBridge-specific
  913. # subnet. This involves creating the network, subnets, internet
  914. # gateway, and connecting it all together so that the network has
  915. # Internet connectivity.
  916. # Check if a default net already exists and get it or create on
  917. default_net = self.provider.networking.networks.get_or_create_default()
  918. # Get/create an internet gateway for the default network and a
  919. # corresponding router if it does not already exist.
  920. # NOTE: Comment this out because the docs instruct users to setup
  921. # network connectivity manually. There's a bit of discrepancy here
  922. # though because the provider-default network will have Internet
  923. # connectivity (unlike the CloudBridge-default network with this
  924. # being commented) and is hence left in the codebase.
  925. # default_gtw = default_net.gateways.get_or_create()
  926. # router_label = "{0}-router".format(
  927. # AWSNetwork.CB_DEFAULT_NETWORK_LABEL)
  928. # default_routers = self.provider.networking.routers.find(
  929. # label=router_label)
  930. # if len(default_routers) == 0:
  931. # default_router = self.provider.networking.routers.create(
  932. # router_label, default_net)
  933. # default_router.attach_gateway(default_gtw)
  934. # else:
  935. # default_router = default_routers[0]
  936. # Create a subnet in each of the region's zones
  937. region = self.provider.compute.regions.get(self.provider.region_name)
  938. default_sn = None
  939. # Determine how many subnets we'll need for the default network and the
  940. # number of available zones. We need to derive a non-overlapping
  941. # network size for each subnet within the parent net so figure those
  942. # subnets here. `<net>.subnets` method will do this but we need to give
  943. # it a prefix. Determining that prefix depends on the size of the
  944. # network and should be incorporate the number of zones. So iterate
  945. # over potential number of subnets until enough can be created to
  946. # accommodate the number of available zones. That is where the fixed
  947. # number comes from in the for loop as that many iterations will yield
  948. # more potential subnets than any region has zones.
  949. ip_net = ipaddress.ip_network(AWSNetwork.CB_DEFAULT_IPV4RANGE)
  950. for x in range(5):
  951. if len(region.zones) <= len(list(ip_net.subnets(
  952. prefixlen_diff=x))):
  953. prefixlen_diff = x
  954. break
  955. subnets = list(ip_net.subnets(prefixlen_diff=prefixlen_diff))
  956. for i, z in reversed(list(enumerate(region.zones))):
  957. sn_label = "{0}-{1}".format(AWSSubnet.CB_DEFAULT_SUBNET_LABEL,
  958. z.id[-1])
  959. log.info("Creating a default CloudBridge subnet %s: %s" %
  960. (sn_label, str(subnets[i])))
  961. sn = self.create(sn_label, default_net, str(subnets[i]), z)
  962. # Create a route table entry between the SN and the inet gateway
  963. # See note above about why this is commented
  964. # default_router.attach_subnet(sn)
  965. if zone and zone_name == z.name:
  966. default_sn = sn
  967. # No specific zone was supplied; return the last created subnet
  968. # The list was originally reversed to have the last subnet be in zone a
  969. if not default_sn:
  970. default_sn = sn
  971. return default_sn
  972. class AWSRouterService(BaseRouterService):
  973. """For AWS, a CloudBridge router corresponds to an AWS Route Table."""
  974. def __init__(self, provider):
  975. super(AWSRouterService, self).__init__(provider)
  976. self.svc = BotoEC2Service(provider=self.provider,
  977. cb_resource=AWSRouter,
  978. boto_collection_name='route_tables')
  979. @dispatch(event="provider.networking.routers.get",
  980. priority=BaseRouterService.STANDARD_EVENT_PRIORITY)
  981. def get(self, router_id):
  982. return self.svc.get(router_id)
  983. @dispatch(event="provider.networking.routers.find",
  984. priority=BaseRouterService.STANDARD_EVENT_PRIORITY)
  985. def find(self, **kwargs):
  986. label = kwargs.pop('label', None)
  987. # All kwargs should have been popped at this time.
  988. if len(kwargs) > 0:
  989. raise InvalidParamException(
  990. "Unrecognised parameters for search: %s. Supported "
  991. "attributes: %s" % (kwargs, 'label'))
  992. log.debug("Searching for AWS Router Service %s", label)
  993. return self.svc.find(filter_name='tag:Name', filter_value=label)
  994. @dispatch(event="provider.networking.routers.list",
  995. priority=BaseRouterService.STANDARD_EVENT_PRIORITY)
  996. def list(self, limit=None, marker=None):
  997. return self.svc.list(limit=limit, marker=marker)
  998. @dispatch(event="provider.networking.routers.create",
  999. priority=BaseRouterService.STANDARD_EVENT_PRIORITY)
  1000. def create(self, label, network):
  1001. network_id = network.id if isinstance(network, AWSNetwork) else network
  1002. cb_router = self.svc.create('create_route_table', VpcId=network_id)
  1003. if label:
  1004. cb_router.label = label
  1005. return cb_router
  1006. @dispatch(event="provider.networking.routers.delete",
  1007. priority=BaseRouterService.STANDARD_EVENT_PRIORITY)
  1008. def delete(self, router):
  1009. r = router if isinstance(router, AWSRouter) else self.get(router)
  1010. if r:
  1011. # pylint:disable=protected-access
  1012. r._route_table.delete()
  1013. class AWSGatewayService(BaseGatewayService):
  1014. def __init__(self, provider):
  1015. super(AWSGatewayService, self).__init__(provider)
  1016. self.svc = BotoEC2Service(provider=provider,
  1017. cb_resource=AWSInternetGateway,
  1018. boto_collection_name='internet_gateways')
  1019. @dispatch(event="provider.networking.gateways.get_or_create",
  1020. priority=BaseGatewayService.STANDARD_EVENT_PRIORITY)
  1021. def get_or_create(self, network):
  1022. network_id = network.id if isinstance(
  1023. network, AWSNetwork) else network
  1024. # Don't filter by label because it may conflict with at least the
  1025. # default VPC that most accounts have but that network is typically
  1026. # without a name.
  1027. gtw = self.svc.find(filter_name='attachment.vpc-id',
  1028. filter_value=network_id)
  1029. if gtw:
  1030. return gtw[0] # There can be only one gtw attached to a VPC
  1031. # Gateway does not exist so create one and attach to the supplied net
  1032. cb_gateway = self.svc.create('create_internet_gateway')
  1033. cb_gateway._gateway.create_tags(
  1034. Tags=[{'Key': 'Name',
  1035. 'Value': AWSInternetGateway.CB_DEFAULT_INET_GATEWAY_NAME
  1036. }])
  1037. cb_gateway._gateway.attach_to_vpc(VpcId=network_id)
  1038. return cb_gateway
  1039. @dispatch(event="provider.networking.gateways.delete",
  1040. priority=BaseGatewayService.STANDARD_EVENT_PRIORITY)
  1041. def delete(self, network, gateway):
  1042. gw = (gateway if isinstance(gateway, AWSInternetGateway)
  1043. else self.svc.get(gateway))
  1044. try:
  1045. if gw.network_id:
  1046. # pylint:disable=protected-access
  1047. gw._gateway.detach_from_vpc(VpcId=gw.network_id)
  1048. except ClientError as e:
  1049. log.warn("Error deleting gateway {0}: {1}".format(self.id, e))
  1050. # pylint:disable=protected-access
  1051. gw._gateway.delete()
  1052. @dispatch(event="provider.networking.gateways.list",
  1053. priority=BaseGatewayService.STANDARD_EVENT_PRIORITY)
  1054. def list(self, network, limit=None, marker=None):
  1055. log.debug("Listing current AWS internet gateways for net %s.",
  1056. network.id)
  1057. fltr = [{'Name': 'attachment.vpc-id', 'Values': [network.id]}]
  1058. return self.svc.list(limit=None, marker=None, Filters=fltr)
  1059. class AWSFloatingIPService(BaseFloatingIPService):
  1060. def __init__(self, provider):
  1061. super(AWSFloatingIPService, self).__init__(provider)
  1062. self.svc = BotoEC2Service(provider=self.provider,
  1063. cb_resource=AWSFloatingIP,
  1064. boto_collection_name='vpc_addresses')
  1065. @dispatch(event="provider.networking.floating_ips.get",
  1066. priority=BaseFloatingIPService.STANDARD_EVENT_PRIORITY)
  1067. def get(self, gateway, fip_id):
  1068. log.debug("Getting AWS Floating IP Service with the id: %s", fip_id)
  1069. return self.svc.get(fip_id)
  1070. @dispatch(event="provider.networking.floating_ips.list",
  1071. priority=BaseFloatingIPService.STANDARD_EVENT_PRIORITY)
  1072. def list(self, gateway, limit=None, marker=None):
  1073. return self.svc.list(limit, marker)
  1074. @dispatch(event="provider.networking.floating_ips.create",
  1075. priority=BaseFloatingIPService.STANDARD_EVENT_PRIORITY)
  1076. def create(self, gateway):
  1077. log.debug("Creating a floating IP under gateway %s", gateway)
  1078. ip = self.provider.ec2_conn.meta.client.allocate_address(
  1079. Domain='vpc')
  1080. return AWSFloatingIP(
  1081. self.provider,
  1082. self.provider.ec2_conn.VpcAddress(ip.get('AllocationId')))
  1083. @dispatch(event="provider.networking.floating_ips.delete",
  1084. priority=BaseFloatingIPService.STANDARD_EVENT_PRIORITY)
  1085. def delete(self, gateway, fip):
  1086. if isinstance(fip, AWSFloatingIP):
  1087. # pylint:disable=protected-access
  1088. aws_fip = fip._ip
  1089. else:
  1090. aws_fip = self.svc.get_raw(fip)
  1091. aws_fip.release()