1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
#
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
from requests import exceptions
from heat.common import exception
from heat.common import template_format
from heat.common import urlfetch
from heat.engine.properties import Properties
from heat.engine import properties
from heat.engine import stack_resource
from heat.openstack.common import log as logging
logger = logging.getLogger(__name__)
class NestedStack(stack_resource.StackResource):
'''
A Resource representing a child stack to allow composition of templates.
'''
PROPERTIES = (
TEMPLATE_URL, TIMEOUT_IN_MINS, PARAMETERS,
) = (
'TemplateURL', 'TimeoutInMinutes', 'Parameters',
)
properties_schema = {
TEMPLATE_URL: properties.Schema(
properties.Schema.STRING,
_('The URL of a template that specifies the stack to be created '
'as a resource.'),
required=True,
update_allowed=True
),
TIMEOUT_IN_MINS: properties.Schema(
properties.Schema.NUMBER,
_('The length of time, in minutes, to wait for the nested stack '
'creation.'),
update_allowed=True
),
PARAMETERS: properties.Schema(
properties.Schema.MAP,
_('The set of parameters passed to this nested stack.'),
update_allowed=True
),
}
update_allowed_keys = ('Properties',)
def child_template(self):
try:
template_data = urlfetch.get(self.properties[self.TEMPLATE_URL])
except (exceptions.RequestException, IOError) as r_exc:
raise ValueError(_("Could not fetch remote template '%(url)s': "
"%(exc)s") %
{'url': self.properties[self.TEMPLATE_URL],
'exc': str(r_exc)})
return template_format.parse(template_data)
def child_params(self):
return self.properties[self.PARAMETERS]
def handle_adopt(self, resource_data=None):
return self._create_with_template(resource_adopt_data=resource_data)
def handle_create(self):
return self._create_with_template()
def _create_with_template(self, resource_adopt_data=None):
template = self.child_template()
return self.create_with_template(template,
self.child_params(),
self.properties[self.TIMEOUT_IN_MINS],
adopt_data=resource_adopt_data)
def handle_delete(self):
return self.delete_nested()
def FnGetAtt(self, key):
if key and not key.startswith('Outputs.'):
raise exception.InvalidTemplateAttribute(resource=self.name,
key=key)
return self.get_output(key.partition('.')[-1])
def FnGetRefId(self):
return self.nested().identifier().arn()
def handle_update(self, json_snippet, tmpl_diff, prop_diff):
# Nested stack template may be changed even if the prop_diff is empty.
self.properties = Properties(self.properties_schema,
json_snippet.get('Properties', {}),
self.stack.resolve_runtime_data,
self.name,
self.context)
try:
template_data = urlfetch.get(self.properties[self.TEMPLATE_URL])
except (exceptions.RequestException, IOError) as r_exc:
raise ValueError(_("Could not fetch remote template '%(url)s': "
"%(exc)s") %
{'url': self.properties[self.TEMPLATE_URL],
'exc': str(r_exc)})
template = template_format.parse(template_data)
return self.update_with_template(template,
self.properties[self.PARAMETERS],
self.properties[self.TIMEOUT_IN_MINS])
def resource_mapping():
return {
'AWS::CloudFormation::Stack': NestedStack,
}
|
