/usr/lib/python2.7/dist-packages/chef/data_bag.py is in python-chef 0.2.3-2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 | import abc
import collections
from chef.api import ChefAPI
from chef.base import ChefObject, ChefQuery, ChefObjectMeta
from chef.exceptions import ChefError, ChefServerNotFoundError
class DataBagMeta(ChefObjectMeta, abc.ABCMeta):
"""A metaclass to allow DataBag to use multiple inheritance."""
class DataBag(ChefObject, ChefQuery):
"""A Chef data bag object.
Data bag items are available via the mapping API. Evaluation works in the
same way as :class:`ChefQuery`, so requesting only the names will not
cause the items to be loaded::
bag = DataBag('versions')
item = bag['web']
for name, item in bag.iteritems():
print item['qa_version']
"""
__metaclass__ = DataBagMeta
url = '/data'
def _populate(self, data):
self.names = data.keys()
def obj_class(self, name, api):
return DataBagItem(self, name, api=api)
class DataBagItem(ChefObject, collections.MutableMapping):
"""A Chef data bag item object.
Data bag items act as normal dicts and can contain arbitrary data.
"""
__metaclass__ = DataBagMeta
url = '/data'
attributes = {
'raw_data': dict,
}
def __init__(self, bag, name, api=None, skip_load=False):
self._bag = bag
super(DataBagItem, self).__init__(str(bag)+'/'+name, api=api, skip_load=skip_load)
self.name = name
@property
def bag(self):
"""The :class:`DataBag` this item is a member of."""
if not isinstance(self._bag, DataBag):
self._bag = DataBag(self._bag, api=self.api)
return self._bag
@classmethod
def from_search(cls, data, api):
bag = data.get('data_bag')
if not bag:
raise ChefError('No data_bag key in data bag item information')
name = data.get('name')
if not name:
raise ChefError('No name key in the data bag item information')
item = name[len('data_bag_item_' + bag + '_'):]
obj = cls(bag, item, api=api, skip_load=True)
obj.exists = True
obj._populate(data)
return obj
def _populate(self, data):
if 'json_class' in data:
self.raw_data = data['raw_data']
else:
self.raw_data = data
def __len__(self):
return len(self.raw_data)
def __iter__(self):
return iter(self.raw_data)
def __getitem__(self, key):
return self.raw_data[key]
def __setitem__(self, key, value):
self.raw_data[key] = value
def __delitem__(self, key):
del self.raw_data[key]
@classmethod
def create(cls, bag, name, api=None, **kwargs):
"""Create a new data bag item. Pass the initial value for any keys as
keyword arguments."""
api = api or ChefAPI.get_global()
obj = cls(bag, name, api, skip_load=True)
for key, value in kwargs.iteritems():
obj[key] = value
obj['id'] = name
api.api_request('POST', cls.url+'/'+str(bag), data=obj.raw_data)
if isinstance(bag, DataBag) and name not in bag.names:
# Mutate the bag in-place if possible, so it will return the new
# item instantly
bag.names.append(name)
return obj
def save(self, api=None):
"""Save this object to the server. If the object does not exist it
will be created.
"""
api = api or self.api
self['id'] = self.name
try:
api.api_request('PUT', self.url, data=self.raw_data)
except ChefServerNotFoundError, e:
api.api_request('POST', self.__class__.url+'/'+str(self._bag), data=self.raw_data)
|