File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/pillar/__pycache__/mongo.cpython-310.pyc
Back
o ;j7 � @ sn d Z ddlZddlZddlZzddlZdZW n ey! dZY nw dd� Ze� e �Z d d d �Z dS ) a� Read Pillar data from a mongodb collection :depends: pymongo (for salt-master) This module will load a node-specific pillar dictionary from a mongo collection. It uses the node's id for lookups and can load either the whole document, or just a specific field from that document as the pillar dictionary. Salt Master Mongo Configuration =============================== The module shares the same base mongo connection variables as :py:mod:`salt.returners.mongo_future_return`. These variables go in your master config file. .. code-block:: yaml mongo.db: <database name> mongo.host: <server ip address> mongo.user: <MongoDB username> mongo.password: <MongoDB user password> mongo.port: 27017 Or single URI: .. code-block:: yaml mongo.uri: URI where uri is in the format: .. code-block:: text mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]] Example: .. code-block:: text mongodb://db1.example.net:27017/mydatabase mongodb://db1.example.net:27017,db2.example.net:2500/?replicaSet=test mongodb://db1.example.net:27017,db2.example.net:2500/?replicaSet=test&connectTimeoutMS=300000 More information on URI format can be found in https://docs.mongodb.com/manual/reference/connection-string/ Configuring the Mongo ext_pillar ================================ The Mongo ext_pillar takes advantage of the fact that the Salt Master configuration file is yaml. It uses a sub-dictionary of values to adjust specific features of the pillar. This is the explicit single-line dictionary notation for yaml. One may be able to get the easier-to-read multi-line dict to work correctly with some experimentation. .. code-block:: yaml ext_pillar: - mongo: {collection: vm, id_field: name, re_pattern: \.example\.com, fields: [customer_id, software, apache_vhosts]} In the example above, we've decided to use the ``vm`` collection in the database to store the data. Minion ids are stored in the ``name`` field on documents in that collection. And, since minion ids are FQDNs in most cases, we'll need to trim the domain name in order to find the minion by hostname in the collection. When we find a minion, return only the ``customer_id``, ``software``, and ``apache_vhosts`` fields, as that will contain the data we want for a given node. They will be available directly inside the ``pillar`` dict in your SLS templates. Module Documentation ==================== � NTFc C s t sdS dS )NFZmongo)� HAS_PYMONGO� r r �E/opt/saltstack/salt/lib/python3.10/site-packages/salt/pillar/mongo.py� __virtual__Z s r �pillar�_id� c C s6 t �d�}t �d�}t �d�} t �d�} t �d�} t �d�} |r@|r*|r*tj�d��tj�|� t�|�} t � d|� | � � }nt � d || � tj|| | | d �} t � d | � | | }|rct �||| �} t � d || � || j|| i|d �}|r�|r�t � d|� nt � d� d|v r�t|d �|d< |S t � d|� i S )a Connect to a mongo database and read per-node pillar information. Parameters: * `collection`: The mongodb collection to read data from. Defaults to ``'pillar'``. * `id_field`: The field in the collection that represents an individual minion id. Defaults to ``'_id'``. * `re_pattern`: If your naming convention in the collection is shorter than the minion id, you can use this to trim the name. `re_pattern` will be used to match the name, and `re_replace` will be used to replace it. Backrefs are supported as they are in the Python standard library. If ``None``, no mangling of the name will be performed - the collection will be searched with the entire minion id. Defaults to ``None``. * `re_replace`: Use as the replacement value in node ids matched with `re_pattern`. Defaults to ''. Feel free to use backreferences here. * `fields`: The specific fields in the document to use for the pillar data. If ``None``, will use the entire document. If using the entire document, the ``_id`` field will be converted to string. Be careful with other fields in the document as they must be string serializable. Defaults to ``None``. z mongo.uriz mongo.hostz mongo.portz mongo.userzmongo.passwordzmongo.dbzMMongo ext_pillar expects either uri or host configuration. Both were providedz%connecting to %s for mongo ext_pillarz(connecting to %s:%s for mongo ext_pillar)�host�port�username�passwordzusing database '%s'zAext_pillar.mongo: looking up pillar def for {'%s': '%s'} in mongo)Z projectionz7ext_pillar.mongo: found document, returning fields '%s'z5ext_pillar.mongo: found document, returning whole docr z4ext_pillar.mongo: no document found in collection %s)Z__opts__�get�salt� exceptionsZSaltConfigurationError�pymongoZ uri_parserZ parse_uriZ MongoClient�log�infoZ get_database�debug�re�subZfind_one�str)Z minion_idr Z collectionZid_fieldZ re_patternZ re_replace�fieldsZurir r �userr Zdb�connZmdb�resultr r r � ext_pillard sL ! � � � r )r r Nr N) �__doc__�loggingr Zsalt.exceptionsr r r � ImportErrorr � getLogger�__name__r r r r r r �<module> s$ L � �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings