diff options
author | root <root@instance-16199.bigstep.io> | 2016-03-02 08:51:16 +0000 |
---|---|---|
committer | root <root@instance-16199.bigstep.io> | 2016-03-02 08:51:16 +0000 |
commit | ab6f166da7290928d56ff3c62a5280536e1d241f (patch) | |
tree | 74305a9c08e6d8d5a3a40df84da0b9ac21fcce63 /cloudinit/sources/DataSourceBigstep.py | |
parent | 97efb9d48197d7098f1abe2ee519418afbe6aec5 (diff) | |
download | vyos-cloud-init-ab6f166da7290928d56ff3c62a5280536e1d241f.tar.gz vyos-cloud-init-ab6f166da7290928d56ff3c62a5280536e1d241f.zip |
Added Bigstep datasource.
Diffstat (limited to 'cloudinit/sources/DataSourceBigstep.py')
-rw-r--r-- | cloudinit/sources/DataSourceBigstep.py | 48 |
1 files changed, 48 insertions, 0 deletions
diff --git a/cloudinit/sources/DataSourceBigstep.py b/cloudinit/sources/DataSourceBigstep.py new file mode 100644 index 00000000..67d43eb3 --- /dev/null +++ b/cloudinit/sources/DataSourceBigstep.py @@ -0,0 +1,48 @@ +# +# Copyright (C) 2015-2016 Bigstep Cloud Ltd. +# +# Author: Alexandru Sirbu <alexandru.sirbu@bigstep.com> +# + +import json + +from cloudinit import log as logging +from cloudinit import sources +from cloudinit import util +from cloudinit import url_helper + +LOG = logging.getLogger(__name__) + + +class DataSourceBigstep(sources.DataSource): + def __init__(self, sys_cfg, distro, paths): + sources.DataSource.__init__(self, sys_cfg, distro, paths) + self.metadata = {} + self.vendordata_raw = "" + self.userdata_raw = "" + + + def get_data(self, apply_filter=False): + url = get_url_from_file() + response = url_helper.readurl(url) + decoded = json.loads(response.contents) + self.metadata = decoded["metadata"] + self.vendordata_raw = decoded["vendordata_raw"] + self.userdata_raw = decoded["userdata_raw"] + return True + + +def get_url_from_file(): + content = util.load_file("/var/lib/cloud/data/seed/bigstep/url") + return content + +# Used to match classes to dependencies +datasources = [ + (DataSourceBigstep, (sources.DEP_FILESYSTEM, sources.DEP_NETWORK)), +] + + +# Return a list of data sources that match this set of dependencies +def get_datasource_list(depends): + return sources.list_from_depends(depends, datasources) + |