Vh.2dZdZdZddlZ ddlZddlmZddlmZddl m Z Gdd Z d Z ed k(re yy#e$rY4wxYw) a? --- module: ecs_cluster version_added: 1.0.0 short_description: Create or terminate ECS clusters. notes: - When deleting a cluster, the information returned is the state of the cluster prior to deletion. - It will also wait for a cluster to have instances registered to it. description: - Creates or terminates ecs clusters. author: - Mark Chance (@Java1Guy) options: state: description: - The desired state of the cluster. required: true choices: ['present', 'absent', 'has_instances'] type: str name: description: - The cluster name. required: true type: str delay: description: - Number of seconds to wait. required: false type: int default: 10 repeat: description: - The number of times to wait for the cluster to have an instance. required: false type: int default: 10 capacity_providers: version_added: 5.2.0 description: - List of capacity providers to use for the cluster. required: false type: list elements: str capacity_provider_strategy: version_added: 5.2.0 description: - List of capacity provider strategies to use for the cluster. required: false type: list elements: dict suboptions: capacity_provider: description: - Name of capacity provider. type: str weight: description: - The relative percentage of the total number of launched tasks that should use the specified provider. type: int base: description: - How many tasks, at a minimum, should use the specified provider. type: int default: 0 purge_capacity_providers: version_added: 5.2.0 description: - Toggle overwriting of existing capacity providers or strategy. This is needed for backwards compatibility. - By default I(purge_capacity_providers=true). required: false type: bool default: true extends_documentation_fragment: - amazon.aws.common.modules - amazon.aws.region.modules - amazon.aws.boto3 a: # Note: These examples do not set authentication details, see the AWS Guide for details. - name: Cluster creation community.aws.ecs_cluster: name: default state: present - name: Cluster creation with capacity providers and strategies. community.aws.ecs_cluster: name: default state: present capacity_providers: - FARGATE - FARGATE_SPOT capacity_provider_strategy: - capacity_provider: FARGATE base: 1 weight: 1 - capacity_provider: FARGATE_SPOT weight: 100 purge_capacity_providers: true - name: Cluster deletion community.aws.ecs_cluster: name: default state: absent - name: Wait for register community.aws.ecs_cluster: name: "{{ new_cluster }}" state: has_instances delay: 10 repeat: 10 register: task_output a activeServicesCount: description: how many services are active in this cluster returned: 0 if a new cluster type: int capacityProviders: version_added: 5.2.0 description: list of capacity providers used in this cluster returned: always type: list defaultCapacityProviderStrategy: version_added: 5.2.0 description: list of capacity provider strategies used in this cluster returned: always type: list clusterArn: description: the ARN of the cluster just created type: str returned: 0 if a new cluster sample: arn:aws:ecs:us-west-2:123456789012:cluster/test-cluster clusterName: description: name of the cluster just created (should match the input argument) type: str returned: always sample: test-cluster pendingTasksCount: description: how many tasks are waiting to run in this cluster returned: 0 if a new cluster type: int registeredContainerInstancesCount: description: how many container instances are available in this cluster returned: 0 if a new cluster type: int runningTasksCount: description: how many tasks are running in this cluster returned: 0 if a new cluster type: int status: description: the status of the new cluster returned: always type: str sample: ACTIVE N)camel_dict_to_snake_dict)snake_dict_to_camel_dict)AnsibleCommunityAWSModulec6eZdZdZdZd dZdZdZdZdZ y) EcsClusterManagerzHandles ECS Clustersc||_ |jd|_y#tjj tjj f$r}|j|dYd}~yd}~wwxYw)NecszFailed to connect to AWSmsg)moduleclientr botocore exceptions ClientError BotoCoreError fail_json_aws)selfr es m/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/aws/plugins/modules/ecs_cluster.py__init__zEcsClusterManager.__init__se  D}}U+DH##//1D1D1R1RS D  (B C C Ds 7A4A//A4cB|D]}||j|s|cSy)N)endswith)rarray_of_clusters cluster_name field_namecs r find_in_arrayzEcsClusterManager.find_in_arrays-" A}%%l3 c|jj|g}t|ddkDr!|j|d|d}|r |ddk(ryt|ddkDr|j|d|}|r|St d|d ) N)clustersfailuresrarnreasonMISSINGr z#Unknown problem describing cluster .)r describe_clusterslenr Exception)rrresponsers rdescribe_clusterz"EcsClusterManager.describe_clusters88-- ~-F x # $q (""8J#7uMAQx[I- x # $q (""8J#7FA=l^1MNNrct|}|rt||d<|rt||d<|jjdi|}|dS)N) clusterNamecapacityProvidersdefaultCapacityProviderStrategycluster)dictrr create_clusterrrcapacity_providerscapacity_provider_strategyparamsr)s rr2z EcsClusterManager.create_clustersX,/ *BCU*VF& ' %8PQk8lF4 5*488**4V4 ""rct|}|rt||d<ng|d<|rt||d<ng|d<|jjdi|}|dS)Nr/r-r.r/r0)r1rr put_cluster_capacity_providersr3s rupdate_clusterz EcsClusterManager.update_clustersnl+ *BCU*VF& '*,F& ' %8PQk8lF4 58:F4 5:488::DVD ""rc:|jj|S)Nr8)r delete_cluster)rr,s rr<z EcsClusterManager.delete_clustersxx&&{&;;rN) clusterArn) __name__ __module__ __qualname____doc__rrr*r2r:r<r0rrrrs%D O# #f+e*# #  Fw h= f@UUX]]`cde`ffgghs2M'' N,01N''N,__main__) DOCUMENTATIONEXAMPLESRETURNrer ImportError0ansible.module_utils.common.dict_transformationsrr>ansible_collections.community.aws.plugins.module_utils.modulesrrbrrtr>r0rrr|srL \# J* X  VUx4<4