VhO'ddlmZmZmZeZdZdZdZddl Z ddl m Z m Z ddl mZddlmZdd lmZ dd lmZmZdd lmZdd lmZd ZGddeZy#e$r ddlmZd Zn #e$rdZYnwxYwY*wxYw))absolute_importdivisionprint_functiona name: mongodb author: - Marcos Diez (@marcosdiez) version_added: "1.0.0" short_description: lookup info from MongoDB description: - 'The ``MongoDB`` lookup runs the *find()* command on a given *collection* on a given *MongoDB* server.' - 'The result is a list of jsons, so slightly different from what PyMongo returns. In particular, *timestamps* are converted to epoch integers.' options: connect_string: description: - Can be any valid MongoDB connection string, supporting authentication, replica sets, etc. - "More info at U(https://docs.mongodb.org/manual/reference/connection-string/)" default: "mongodb://localhost/" database: description: - Name of the database which the query will be made required: True collection: description: - Name of the collection which the query will be made required: True filter: description: - Criteria of the output type: 'dict' default: {} projection: description: - Fields you want returned type: dict default: {} skip: description: - How many results should be skipped type: integer limit: description: - How many results should be shown type: integer sort: description: - Sorting rules. - Please use the strings C(ASCENDING) and C(DESCENDING) to set the order. - Check the example for more information. type: list elements: list default: [] extra_connection_parameters: description: - Extra connection parameters that to be sent to pymongo.MongoClient - Check the example to see how to connect to mongo using an SSL certificate. - "All possible parameters are here: U(https://pymongo.readthedocs.io/en/stable/api/pymongo/mongo_client.html#pymongo.mongo_client.MongoClient)" type: dict default: {} notes: - "Please check https://pymongo.readthedocs.io/en/stable/api/pymongo/collection.html#pymongo.collection.Collection.find for more details." requirements: - pymongo >= 2.4 (python library) a - hosts: localhost gather_facts: false vars: mongodb_parameters: #mandatory parameters database: 'local' collection: "startup_log" #optional connection_string: "mongodb://localhost/" # connection_string: "mongodb://username:password@my.server.com:27017/" # extra_connection_parameters: { "ssl" : True , "ssl_certfile": /etc/self_signed_certificate.pem" } #optional query parameters, we accept any parameter from the normal mongodb query. # filter: { "hostname": "u18" } projection: { "pid": True , "_id" : False , "hostname" : True } skip: 0 limit: 1 sort: [ [ "startTime" , "ASCENDING" ] , [ "age", "DESCENDING" ] ] tasks: - debug: msg="The PID from MongoDB is {{ lookup('mongodb', mongodb_parameters ).pid }}" - debug: msg="The HostName from the MongoDB server is {{ lookup('mongodb', mongodb_parameters ).hostname }}" - debug: msg="Mongo DB is stored at {{ lookup('mongodb', mongodb_parameters_inline )}}" vars: mongodb_parameters_inline: database: 'local' collection: "startup_log" connection_string: "mongodb://localhost/" limit: 1 projection: { "cmdline.storage": True } # lookup syntax, does the same as below - debug: msg="The hostname is {{ item.hostname }} and the pid is {{ item.pid }}" loop: "{{ lookup('mongodb', mongodb_parameters, wantlist=True) }}" # query syntax, does the same as above - debug: msg="The hostname is {{ item.hostname }} and the pid is {{ item.pid }}" loop: "{{ query('mongodb', mongodb_parameters) }}" - name: "Raw output from the mongodb lookup (a json with pid and hostname )" debug: msg="{{ lookup('mongodb', mongodb_parameters) }}" - name: "Yet another mongodb query, now with the parameters on the task itself" debug: msg="pid={{item.pid}} hostname={{item.hostname}} version={{ item.buildinfo.version }}" with_mongodb: - database: 'local' collection: "startup_log" connection_string: "mongodb://localhost/" limit: 1 projection: { "pid": True , "hostname": True , "buildinfo.version": True } # Please notice this specific query may result more than one result. This is expected - name: "Shows the whole output from mongodb" debug: msg="{{ item }}" with_mongodb: - database: 'local' collection: "startup_log" connection_string: "mongodb://localhost/" zr _list_of_jsons: description: - a list of JSONs with the results of the MongoDB query. type: list N) string_types integer_types) to_native) AnsibleError) LookupBase) ASCENDING DESCENDING)ConnectionFailure) MongoClientT) ConnectionFc*eZdZdZdZdZdZdZy) LookupModulec||St|tstdj||D]}|j ||S)Nz2Error. Sort parameters must be a list, not [ {0} ]) isinstancelistr format _convert_sort_string_to_constant)selfsort_parameteritems l/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/mongodb/plugins/lookup/mongodb.py_fix_sort_parameterz LookupModule._fix_sort_parametersU  !! !.$/T[[\jkl l" 8D  1 1$ 7 8cj|d}|j}|dk(r t|d<y|dk(r t|d<yy)Nr r )upperr r )rroriginal_sort_order sort_orders rrz-LookupModule._convert_sort_string_to_constantsA"1g(..0  %DG = ( DG)rc ||St|tttfzr|St|tr|St|t r+g}|D]"}|j |j|$|St|tr2i}|jD]}||}|j|||<|St|tjr(|tjdddz jSdj|S)Nirz{0}) rrfloatboolrrappend"convert_mongo_result_to_valid_jsondictkeysdatetime total_secondsr)rresultnew_listelemnew_dictkeyvalues rr&z/LookupModule.convert_mongo_result_to_valid_jsons >M fmudm; <M fl +M  %H O G G MN OO  %H{{} Os  $ G G N  OO  1 1 2X..tQ::JJL L==( (rc |j|S#t$r*}tdjt ||d}~wwxYw)Nz1There was an exception on the mongodb_lookup: {0}) _run_helper Exceptionprintrr)rterms variableskwargses rrunzLookupModule.runsF ##E* *  FMMiXYl[ \G s A%AAc*ts tdg}|D]}dD] }||vstdj||jdd}|d}|d}|jdi}d|vr|d=d|vr|d=|d=|d=d |vr|j |d |d < t |fi|} | ||j d i|} | D]$} |j| } |j| &|S#t$r} td t| zd} ~ wwxYw) NzJpymongo is required in the control node (this machine) for mongodb lookup.)database collectionz!missing mandatory parameter [{0}]connection_stringzmongodb://localhostr;r<extra_connection_parameterssortz!unable to connect to database: %s) pymongo_foundr rgetrrfindr&r%r str) rr5rettermrequired_parameterr=r;r<r>clientresultsr+r8s rr2zLookupModule._run_helpersxlm m RD&B h"%T1&'K'R'RSe'fgg h!%)=?U V K(Hm,J*.((3QSU*V '-578#t+-.[!]#$ $ 8 8g GW  R$%6V:UV;&*:6;;CdC%'F!DDVLFJJv&'5 RB % R"#G#a&#PQQ RsA C-- D6D  DN)__name__ __module__ __qualname__rrr&r9r2r@rrrrs !)2%rr) __future__rrrtype __metaclass__ DOCUMENTATIONEXAMPLESRETURNr)ansible.module_utils.sixrransible.module_utils._textransible.errorsr ansible.plugins.lookupr pymongor r pymongo.errorsr rrA ImportErrorrrr@rrrZs&CB < |= ~ @0'- -0#M\:\5   s5AA3A# A3#A-*A3,A--A32A3