LSST Applications  21.0.0-172-gfb10e10a+18fedfabac,22.0.0+297cba6710,22.0.0+80564b0ff1,22.0.0+8d77f4f51a,22.0.0+a28f4c53b1,22.0.0+dcf3732eb2,22.0.1-1-g7d6de66+2a20fdde0d,22.0.1-1-g8e32f31+297cba6710,22.0.1-1-geca5380+7fa3b7d9b6,22.0.1-12-g44dc1dc+2a20fdde0d,22.0.1-15-g6a90155+515f58c32b,22.0.1-16-g9282f48+790f5f2caa,22.0.1-2-g92698f7+dcf3732eb2,22.0.1-2-ga9b0f51+7fa3b7d9b6,22.0.1-2-gd1925c9+bf4f0e694f,22.0.1-24-g1ad7a390+a9625a72a8,22.0.1-25-g5bf6245+3ad8ecd50b,22.0.1-25-gb120d7b+8b5510f75f,22.0.1-27-g97737f7+2a20fdde0d,22.0.1-32-gf62ce7b1+aa4237961e,22.0.1-4-g0b3f228+2a20fdde0d,22.0.1-4-g243d05b+871c1b8305,22.0.1-4-g3a563be+32dcf1063f,22.0.1-4-g44f2e3d+9e4ab0f4fa,22.0.1-42-gca6935d93+ba5e5ca3eb,22.0.1-5-g15c806e+85460ae5f3,22.0.1-5-g58711c4+611d128589,22.0.1-5-g75bb458+99c117b92f,22.0.1-6-g1c63a23+7fa3b7d9b6,22.0.1-6-g50866e6+84ff5a128b,22.0.1-6-g8d3140d+720564cf76,22.0.1-6-gd805d02+cc5644f571,22.0.1-8-ge5750ce+85460ae5f3,master-g6e05de7fdc+babf819c66,master-g99da0e417a+8d77f4f51a,w.2021.48
LSST Data Management Base Package
Public Member Functions | Public Attributes | List of all members
lsst.daf.persistence.access.Access Class Reference

Public Member Functions

def cfg (cls, storageCfg)
 
def __init__ (self, cfg)
 
def __repr__ (self)
 
def mapperClass (self)
 
def root (self)
 
def locationWithRoot (self, location)
 
def setCfg (self, repoCfg)
 
def loadCfg (self)
 
def write (self, butlerLocation, obj)
 
def read (self, butlerLocation)
 
def exists (self, location)
 
def lookup (self, *args, **kwargs)
 

Public Attributes

 storage
 

Detailed Description

Implements an butler framework interface for Transport, Storage, and Registry

.. warning::

    Access is 'wet paint' and very likely to change. Use of it in production
    code other than via the 'old butler' API is strongly discouraged.

Definition at line 36 of file access.py.

Constructor & Destructor Documentation

◆ __init__()

def lsst.daf.persistence.access.Access.__init__ (   self,
  cfg 
)
Initializer

:param cfg: a Policy that defines the configuration for this class. It is recommended that the cfg be
            created by calling Access.cfg()
:return:

Definition at line 55 of file access.py.

55  def __init__(self, cfg):
56  """Initializer
57 
58  :param cfg: a Policy that defines the configuration for this class. It is recommended that the cfg be
59  created by calling Access.cfg()
60  :return:
61  """
62  self.storage = cfg['storageCfg.cls'](cfg['storageCfg'])
63 

Member Function Documentation

◆ __repr__()

def lsst.daf.persistence.access.Access.__repr__ (   self)

Definition at line 64 of file access.py.

64  def __repr__(self):
65  return 'Access(storage=%s)' % self.storage
66 

◆ cfg()

def lsst.daf.persistence.access.Access.cfg (   cls,
  storageCfg 
)
Helper func to create a properly formatted Policy to configure an Access instance.

:param storageCfg: a cfg to instantiate a storage.
:return:

Definition at line 47 of file access.py.

47  def cfg(cls, storageCfg):
48  """Helper func to create a properly formatted Policy to configure an Access instance.
49 
50  :param storageCfg: a cfg to instantiate a storage.
51  :return:
52  """
53  return AccessCfg(cls=cls, storageCfg=storageCfg)
54 

◆ exists()

def lsst.daf.persistence.access.Access.exists (   self,
  location 
)
Query if a location exists.

As of this writing the only storage type is PosixStorage, and it works to say that 'location' is a
simple locaiton descriptor. In the case of PosixStorage that's a path. If this needs to become more
complex it could be changed to be a butlerLocation, or something else, as needed.
:param location: a simple location descriptor, type is dependent on Storage.
:return: True if location exists, else False.

Definition at line 125 of file access.py.

125  def exists(self, location):
126  """Query if a location exists.
127 
128  As of this writing the only storage type is PosixStorage, and it works to say that 'location' is a
129  simple locaiton descriptor. In the case of PosixStorage that's a path. If this needs to become more
130  complex it could be changed to be a butlerLocation, or something else, as needed.
131  :param location: a simple location descriptor, type is dependent on Storage.
132  :return: True if location exists, else False.
133  """
134  return self.storage.exists(location)
135 

◆ loadCfg()

def lsst.daf.persistence.access.Access.loadCfg (   self)
Reads the repository configuration from Storage.

:return: the Policy cfg

Definition at line 101 of file access.py.

101  def loadCfg(self):
102  """Reads the repository configuration from Storage.
103 
104  :return: the Policy cfg
105  """
106  return self.storage.loadCfg()
107 

◆ locationWithRoot()

def lsst.daf.persistence.access.Access.locationWithRoot (   self,
  location 
)
Given a location, get a fully qualified handle to location including storage root.

Note; at the time of this writing the only existing storage type is PosixStorage. This returns the
root+location.
:param location:
:return:

Definition at line 83 of file access.py.

83  def locationWithRoot(self, location):
84  """Given a location, get a fully qualified handle to location including storage root.
85 
86  Note; at the time of this writing the only existing storage type is PosixStorage. This returns the
87  root+location.
88  :param location:
89  :return:
90  """
91  return self.storage.locationWithRoot(location)
92 

◆ lookup()

def lsst.daf.persistence.access.Access.lookup (   self,
args,
**  kwargs 
)
Perform a lookup in the registry.

Returns a list of dataId for each valid lookup (right? TODO VERIFY)

Definition at line 136 of file access.py.

136  def lookup(self, *args, **kwargs):
137  """Perform a lookup in the registry.
138 
139  Returns a list of dataId for each valid lookup (right? TODO VERIFY)"""
140  return self.storage.lookup(*args, **kwargs)

◆ mapperClass()

def lsst.daf.persistence.access.Access.mapperClass (   self)
Get the mapper class associated with a repository root.

:return: the mapper class

Definition at line 67 of file access.py.

67  def mapperClass(self):
68  """Get the mapper class associated with a repository root.
69 
70  :return: the mapper class
71  """
72  return self.storage.mapperClass()
73 

◆ read()

def lsst.daf.persistence.access.Access.read (   self,
  butlerLocation 
)
Reads an object from storage

:param butlerLocation: describes the location & how to load the object.
:return:

Definition at line 117 of file access.py.

117  def read(self, butlerLocation):
118  """Reads an object from storage
119 
120  :param butlerLocation: describes the location & how to load the object.
121  :return:
122  """
123  return self.storage.read(butlerLocation=butlerLocation)
124 
std::shared_ptr< table::io::Persistable > read(table::io::InputArchive const &archive, table::io::CatalogVector const &catalogs) const override
Definition: warpExposure.cc:0

◆ root()

def lsst.daf.persistence.access.Access.root (   self)
Get the repository root as defined by the Storage class, this refers to the 'top' of a persisted
repository. The exact type of Root can vary based on Storage type.

:return: the root of the persisted repository.

Definition at line 74 of file access.py.

74  def root(self):
75  """Get the repository root as defined by the Storage class, this refers to the 'top' of a persisted
76  repository. The exact type of Root can vary based on Storage type.
77 
78  :return: the root of the persisted repository.
79  """
80 
81  return self.storage.root
82 

◆ setCfg()

def lsst.daf.persistence.access.Access.setCfg (   self,
  repoCfg 
)
Writes the repository configuration to Storage.

:param repoCfg: the Policy cfg to be written
:return: None

Definition at line 93 of file access.py.

93  def setCfg(self, repoCfg):
94  """Writes the repository configuration to Storage.
95 
96  :param repoCfg: the Policy cfg to be written
97  :return: None
98  """
99  self.storage.setCfg(repoCfg)
100 

◆ write()

def lsst.daf.persistence.access.Access.write (   self,
  butlerLocation,
  obj 
)
Passes an object to Storage to be written into the repository.

:param butlerLocation: the location & formatting for the object to be written.
:param obj: the object to be written.
:return: None

Definition at line 108 of file access.py.

108  def write(self, butlerLocation, obj):
109  """Passes an object to Storage to be written into the repository.
110 
111  :param butlerLocation: the location & formatting for the object to be written.
112  :param obj: the object to be written.
113  :return: None
114  """
115  self.storage.write(butlerLocation, obj)
116 
void write(OutputArchiveHandle &handle) const override

Member Data Documentation

◆ storage

lsst.daf.persistence.access.Access.storage

Definition at line 62 of file access.py.


The documentation for this class was generated from the following file: