Vh!#ddlmZmZmZeZdZdZdZddl Z ddl m Z m Z ddl mZddlm Z mZmZmZmZmZmZd Zd Zd Zd Zd ZdZdZedk(reyy))absolute_importdivisionprint_functiona --- module: mongodb_shard short_description: Add or remove shards from a MongoDB Cluster description: - Add or remove shards from a MongoDB Cluster. author: Rhys Campbell (@rhysmeister) version_added: "1.0.0" extends_documentation_fragment: - community.mongodb.login_options - community.mongodb.ssl_options options: shard: description: - The shard connection string. - Should be supplied in the form /host:port as detailed in U(https://docs.mongodb.com/manual/tutorial/add-shards-to-shard-cluster/). - For example rs0/example1.mongodb.com:27017. required: true type: str sharded_databases: description: - Enable sharding on the listed database. - Can be supplied as a string or a list of strings. - Sharding cannot be disabled on a database. - Starting in MongoDB 6.0, the enableSharding command is no longer required to shard a collection and this parameter is ignored. required: false type: raw mongos_process: description: - Provide a custom name for the mongos process you are connecting to. - Most users can ignore this setting. required: false type: str default: "mongos" state: description: - Whether the shard should be present or absent from the Cluster. required: false type: str default: present choices: - "absent" - "present" notes: - Requires the pymongo Python package on the remote host, version 4+. requirements: [ pymongo ] a" - name: Add a replicaset shard named rs1 with a member running on port 27018 on mongodb0.example.net community.mongodb.mongodb_shard: login_user: admin login_password: admin shard: "rs1/mongodb0.example.net:27018" state: present - name: Add a standalone mongod shard running on port 27018 of mongodb0.example.net community.mongodb.mongodb_shard: login_user: admin login_password: admin shard: "mongodb0.example.net:27018" state: present - name: To remove a shard called 'rs1' community.mongodb.mongodb_shard: login_user: admin login_password: admin shard: rs1 state: absent # Single node shard running on localhost - name: Ensure shard rs0 exists community.mongodb.mongodb_shard: login_user: admin login_password: secret shard: "rs0/localhost:3001" state: present # Single node shard running on localhost - name: Ensure shard rs1 exists community.mongodb.mongodb_shard: login_user: admin login_password: secret shard: "rs1/localhost:3002" state: present # Enable sharding on a few databases when creating the shard - name: To remove a shard called 'rs1' community.mongodb.mongodb_shard: login_user: admin login_password: admin shard: rs1 sharded_databases: - db1 - db2 state: present a mongodb_shard: description: The name of the shard to create. returned: success type: str sharded_enabled: description: Databases that have had sharding enabled during module execution. returned: success when sharding is enabled type: list N) AnsibleModulemissing_required_lib) to_native)rmongodb_common_argument_spec mongo_authPYMONGO_IMP_ERR pymongo_foundget_mongodb_clientcheck_srv_versioncd|vr|jdd}n|}|djjd|iD]}|cSy)zCheck if a shard exists. Args: client (cursor): Mongodb cursor on admin database. shard (str): shard to check. Returns: dict: when user exists, False otherwise. /rconfig_idF)splitshardsfind)clientshardss s/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/mongodb/plugins/modules/mongodb_shard.py shard_findrsT e| KK Q  !((--uaj9  cX |djd|}|S#t$r}|d}~wwxYw)NadminaddShardcommand Exceptionrrshexceps r shard_addr%s; G_ $ $Z 7 I   )$)cX |djd|}|S#t$r}|d}~wwxYw)Nr removeShardrr"s r shard_remover)s; G_ $ $]E : I  r&cg}|djjddiddiD]}|j|d|S)z Returns the sharded databases Args: client (cursor): Mongodb cursor on admin database. Returns: a list of database names that are sharded r partitionedTr) databasesrappend)rsharded_databasesentrys r sharded_dbsr1sS!++00-1FPQ S/  u./ rc<d}|djd|}|rd}|S)z Enables sharding on a database Args: client (cursor): Mongodb cursor on admin database. Returns: true on success, false on failure FrenableShardingT)r )rdatabaserdbs renable_database_shardingr6s- A  !18 r?rawpresentabsent)r>r?r@choices)mongos_processrr/state login_userlogin_password) argument_specsupports_check_moderequired_togetherpymongo)msg exception login_host login_portrrFr/rEz Unable to connect to MongoDB: %s)rMr serverStatusprocessz'Process running on {0}:{1} is not a {2}raddremovezUnable to {0} shard: %s)changedrsharded_enabled)r updatedictrr fail_jsonrr paramsr r r!rr formatintr isinstancer<listr: check_moderlenr%r6r) traceback format_exc exit_json)rImodulerOrPrrFr/rErr$r8rVr5eactionresults rmainrjs'02MI-EE:y8U^J_`  # (*:;<F 1)<#2  4|,J|,J MM' "E MM' "E &9:]]#34NT#F+FF+*x '? " "> 29 = O   !J!Q!QR\^hjx!y  z  (S1B661RST1U-VYZ-Z+S1$():$;!+F4EFL    !!&%0C 4E4I"G("!&%0#G"G !!&%0fe,"G#G|$q(*=0<="G("fe, /"G#GF <1$0 !Fvm T?)EBRRSSTR x H F6==fE RS T`i`t`t`vww xs2#I;D2J  J !JJ  K)A K$$K)__main__) __future__rrrr> __metaclass__ DOCUMENTATIONEXAMPLESRETURNrcansible.module_utils.basicrransible.module_utils._textrIansible_collections.community.mongodb.plugins.module_utils.mongodb_commonr r r r r rrr%r)r1r6r:rj__name__rXrrrus} A@ 1 f0 d J0&    &Rj zFr