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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
# Copyright 2012-2015 Canonical Ltd. This software is licensed under the
# GNU Affero General Public License version 3 (see the file LICENSE).
"""Low-level composition code for preseeds."""
from __future__ import (
absolute_import,
print_function,
unicode_literals,
)
str = None
__metaclass__ = type
__all__ = [
'compose_preseed',
]
from urllib import urlencode
from maasserver.clusterrpc.osystems import get_preseed_data
from maasserver.enum import PRESEED_TYPE
from maasserver.utils import absolute_reverse
from provisioningserver.rpc.exceptions import (
NoConnectionsAvailable,
NoSuchOperatingSystem,
)
import yaml
def compose_cloud_init_preseed(token, base_url=''):
"""Compose the preseed value for a node in any state but Commissioning."""
credentials = urlencode({
'oauth_consumer_key': token.consumer.key,
'oauth_token_key': token.key,
'oauth_token_secret': token.secret,
})
local_config_yaml = yaml.safe_dump({
# Do not let cloud-init override /etc/hosts/: use the default
# behavior which means running `dns_resolve(hostname)` on a node
# will query the DNS server (and not return 127.0.0.1).
# See bug 1087183 for details.
"manage_etc_hosts": False,
"apt_preserve_sources_list": True,
})
# this is debconf escaping
local_config = local_config_yaml.replace("\\", "\\\\").replace("\n", "\\n")
# Preseed data to send to cloud-init. We set this as MAAS_PRESEED in
# ks_meta, and it gets fed straight into debconf.
preseed_items = [
('datasources', 'multiselect', 'MAAS'),
('maas-metadata-url', 'string', absolute_reverse(
'metadata', base_url=base_url)),
('maas-metadata-credentials', 'string', credentials),
('local-cloud-config', 'string', local_config)
]
return '\n'.join(
"cloud-init cloud-init/%s %s %s" % (
item_name,
item_type,
item_value,
)
for item_name, item_type, item_value in preseed_items)
def compose_commissioning_preseed(token, base_url=''):
"""Compose the preseed value for a Commissioning node."""
metadata_url = absolute_reverse('metadata', base_url=base_url)
return _compose_cloud_init_preseed(token, metadata_url)
def compose_curtin_preseed(token, base_url=''):
"""Compose the preseed value for a node being installed with curtin."""
metadata_url = absolute_reverse('curtin-metadata', base_url=base_url)
return _compose_cloud_init_preseed(token, metadata_url)
def _compose_cloud_init_preseed(token, metadata_url):
return "#cloud-config\n%s" % yaml.safe_dump({
'datasource': {
'MAAS': {
'metadata_url': metadata_url,
'consumer_key': token.consumer.key,
'token_key': token.key,
'token_secret': token.secret,
}
}
})
def _get_metadata_url(preseed_type, base_url):
if preseed_type == PRESEED_TYPE.CURTIN:
return absolute_reverse('curtin-metadata', base_url=base_url)
else:
return absolute_reverse('metadata', base_url=base_url)
def compose_preseed(preseed_type, node):
"""Put together preseed data for `node`.
This produces preseed data for the node in different formats depending
on the preseed_type.
:param preseed_type: The type of preseed to compose.
:type preseed_type: string
:param node: The node to compose preseed data for.
:type node: Node
:return: Preseed data containing the information the node needs in order
to access the metadata service: its URL and auth token.
"""
# Circular import.
from metadataserver.models import NodeKey
token = NodeKey.objects.get_token_for_node(node)
base_url = node.nodegroup.maas_url
if preseed_type == PRESEED_TYPE.COMMISSIONING:
return compose_commissioning_preseed(token, base_url)
else:
metadata_url = _get_metadata_url(preseed_type, base_url)
try:
return get_preseed_data(preseed_type, node, token, metadata_url)
except NotImplementedError:
# This is fine; it indicates that the OS does not specify
# any special preseed data for this type of preseed.
pass
except NoSuchOperatingSystem:
# Let a caller handle this. If rendered for presentation in the
# UI, an explanatory error message could be displayed. If rendered
# via the API, in response to cloud-init for example, the prudent
# course of action might be to turn the node's power off, mark it
# as broken, and notify the user.
raise
except NoConnectionsAvailable:
# This means that the region is not in contact with the node's
# cluster controller. In the UI this could be shown as an error
# message. This is, however, a show-stopping problem when booting
# or installing a node. A caller cannot turn the node's power off
# via the usual methods because they rely on a connection to the
# cluster. This /could/ generate a preseed that aborts the boot or
# installation. The caller /could/ mark the node as broken. For
# now, let the caller make the decision, which might be to retry.
raise
# There is no OS-specific preseed data.
if preseed_type == PRESEED_TYPE.CURTIN:
return compose_curtin_preseed(token, base_url)
else:
return compose_cloud_init_preseed(token, base_url)
|