&`iwHHddlZddlZddlmZddlmZmZddlmZddl m Z ddl m Z ddl mZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0GddZ1dS)N)client)ClientExceptionServerException)AllocatePublicIpAddressRequest)AuthorizeSecurityGroupRequest)CreateInstanceRequest)CreateKeyPairRequest)CreateSecurityGroupRequest)CreateVpcRequest)CreateVSwitchRequest)DeleteInstanceRequest)DeleteInstancesRequest)DeleteKeyPairsRequest)DescribeInstancesRequest)DescribeKeyPairsRequest)DescribeSecurityGroupsRequest)DescribeVpcsRequest)DescribeVSwitchesRequest)ImportKeyPairRequest)RunInstancesRequest)StartInstanceRequest)StopInstanceRequest)StopInstancesRequest)TagResourcesRequestceZdZdZdZd#dZ d$d Z d%d Zd Zd#dZ dZ dZ dZ dZ d&dZdZd'dZd(dZdZdZdZdZdZdZd)d Zd)d!Zd"ZdS)* AcsClienta A wrapper around Aliyun SDK. We use this wrapper in aliyun node provider. Parameters: access_key: The AccessKey ID of your aliyun account. access_key_secret: The AccessKey secret of your aliyun account. region_id: A region is a geographic area where a data center resides. Region_id is the ID of region (e.g., cn-hangzhou, us-west-1, etc.) max_retries: The maximum number of retries each connection. c@tj|||||_dS)N)aksecretmax_retry_time region_id)rrcli)self access_keyaccess_key_secretr! max_retriess x/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/autoscaler/_private/aliyun/utils.py__init__zAcsClient.__init__8s+#$&    Nct}||||||||}|*|dd}|SdS)zQuery the details of one or more Elastic Compute Service (ECS) instances. :param tags: The tags of the instance. :param instance_ids: The IDs of ECS instances :return: ECS instance list N InstancesInstance)rset_Tagsset_InstanceIds _send_requestget)r#tags instance_idsrequestresponse instance_lists r'describe_instanceszAcsClient.describe_instances@s+,,     T " " "  #  # #L 1 1 1%%g..  $LL5599*EEM tr) optimizedPostPaidSpotWithPriceLimit PayByTrafficc Jt} | || || || || || || | | || || | } | ,| d} tj d| | StjddS)aCreate a subscription or pay-as-you-go ECS instance. :param instance_type: The instance type of the ECS. :param image_id: The ID of the image used to create the instance. :param tags: The tags of the instance. :param key_pair_name: The name of the key pair to be bound to the instance. :param optimized: Specifies whether the instance is I/O optimized :param instance_charge_type: The billing method of the instance. Default value: PostPaid. :param spot_strategy: The preemption policy for the pay-as-you-go instance. :param internet_charge_type: The billing method for network usage. Default value: PayByTraffic. :param internet_max_bandwidth_out: The maximum inbound public bandwidth. Unit: Mbit/s. :return: The created instance ID. N InstanceIdz-instance %s created task submit successfully.instance created failed.)rset_InstanceType set_ImageIdset_IoOptimizedset_InstanceChargeTypeset_SpotStrategyset_InternetChargeTypeset_InternetMaxBandwidthOutset_KeyPairNamer-r/r0logginginfoerror) r# instance_typeimage_idr1 key_pair_namer7instance_charge_type spot_strategyinternet_charge_typeinternet_max_bandwidth_outr3r4 instance_ids r'create_instancezAcsClient.create_instanceRs<())  ///H%%% ***&&';<<<  ///&&';<<<++,FGGG ...%%g..  ",,|44K LH+ V V V  0111tr)c t} | || || || | | | | | | | | || || || || || | }|*|dd}|StjddS)aCreate one or more pay-as-you-go or subscription Elastic Compute Service (ECS) instances :param instance_type: The instance type of the ECS. :param image_id: The ID of the image used to create the instance. :param tags: The tags of the instance. :param security_group_id: The ID of the security group to which to assign the instance. Instances in the same security group can communicate with each other. :param vswitch_id: The ID of the vSwitch to which to connect the instance. :param key_pair_name: The name of the key pair to be bound to the instance. :param amount: The number of instances that you want to create. :param optimized: Specifies whether the instance is I/O optimized :param instance_charge_type: The billing method of the instance. Default value: PostPaid. :param spot_strategy: The preemption policy for the pay-as-you-go instance. :param internet_charge_type: The billing method for network usage. Default value: PayByTraffic. :param internet_max_bandwidth_out: The maximum inbound public bandwidth. Unit: Mbit/s. :return: The created instance IDs. NInstanceIdSets InstanceIdSetr>)rr?r@rArBrCrDrEr- set_Amountset_SecurityGroupId set_VSwitchIdrFr/r0rGrI)r#rJrKr1security_group_id vswitch_idrLamountr7rMrNrOrPr3r4r2s r' run_instanceszAcsClient.run_instancessYR&''  ///H%%% ***&&';<<<  ///&&';<<<++,FGGG6"""##$5666j))) ...%%g..  #<<(899==oNNL  0111tr)ct}||||}||d}|SdS)zCreate a security group :param vpc_id: The ID of the VPC in which to create the security group. :return: The created security group ID. NSecurityGroupId)r set_VpcIdr/r0)r#vpc_idr3r4rZs r'create_security_groupzAcsClient.create_security_groupsZ-..&!!!%%g..   ( -> ? ? $ $tr)c(t}||||||||}|*|dd}|St jddS)zQuery basic information of security groups. :param vpc_id: The ID of the VPC to which the security group belongs. :param tags: The tags of the security group. :return: Security group list. NSecurityGroups SecurityGroupzdescribe security group failed.)rr`r-r/r0rGrI)r#rar1r3r4security_groupss r'describe_security_groupsz"AcsClient.describe_security_groupss011     f % % %     T " " "%%g..  &ll+;<<@@QQO" " 7888tr)ct}||||||||||dS)aCreate an inbound security group rule. :param ip_protocol: The transport layer protocol. :param port_range: The range of destination ports relevant to the transport layer protocol. :param security_group_id: The ID of the destination security group. :param source_cidr_ip: The range of source IPv4 addresses. CIDR blocks and IPv4 addresses are supported. N)rset_IpProtocol set_PortRangerXset_SourceCidrIpr/)r# ip_protocol port_rangerZsource_cidr_ipr3s r'authorize_security_groupz"AcsClient.authorize_security_groupsz011{+++j)))##$5666  000 7#####r)c"t}||||||||}||dSt jd|dS)a?Create vSwitches to divide the VPC into one or more subnets :param vpc_id: The ID of the VPC to which the VSwitch belongs. :param zone_id: The ID of the zone to which the target VSwitch belongs. :param cidr_block: The CIDR block of the VSwitch. :return: N VSwitchIdz!create_v_switch vpc_id %s failed.)r set_ZoneIdr` set_CidrBlockr/r0rGrI)r#razone_id cidr_blockr3r4s r'create_v_switchzAcsClient.create_v_switchs'((7###&!!!j)))%%g..  << ,, , M=v F F Ftr)czt}||}||dSdS)zUCreates a virtual private cloud (VPC). :return: The created VPC ID. NVpcId)r r/r0r#r3r4s r' create_vpczAcsClient.create_vpc s? #$$%%g..  <<(( (tr)ct}||}|(|ddSdS)zJQueries one or more VPCs in a region. :return: VPC list. NVpcsVpc)rr/r0rys r' describe_vpcszAcsClient.describe_vpcssM &''%%g..  <<''++E22 2tr)instancec&t}||||||||}|t jd|dSt jd|dS)zCreate and bind tags to specified ECS resources. :param resource_ids: The IDs of N resources. :param tags: The tags of the resource. :param resource_type: The type of the resource. Nz$instance %s create tag successfully.zinstance %s create tag failed.)rr-set_ResourceTypeset_ResourceIdsr/rGrHrI)r# resource_idsr1 resource_typer3r4s r' tag_resourcezAcsClient.tag_resource s&''  /// ---%%g..   L? N N N N N M:L I I I I Ir)ct}||||}|tjd|dStjd|dS)zQStart an ECS instance. :param instance_id: The Ecs instance ID. Nzinstance %s start successfully.zinstance %s start failed.)rset_InstanceIdr/rGrHrIr#rQr3r4s r'start_instancezAcsClient.start_instance1sn '(({+++%%g..   L:K H H H H H M5{ C C C C Cr)Fct}||||tjd|||dS)zStop an ECS instance that is in the Running state. :param instance_id: The Ecs instance ID. :param force_stop: Specifies whether to forcibly stop the instance. :return: z$Stop %s command submit successfully.N)rr set_ForceStoprGrHr/)r#rQ force_stopr3s r' stop_instancezAcsClient.stop_instance?sd&''{+++j))) ;[III 7#####r) StopChargingct}||||||}|t jddSdS)aStop one or more ECS instances that are in the Running state. :param instance_ids: The IDs of instances. :param stopped_mode: Specifies whether billing for the instance continues after the instance is stopped. Nzstop_instances failed)rr.set_StoppedModer/rGrI)r#r2 stopped_moder3r4s r'stop_instanceszAcsClient.stop_instancesLso'(( --- ---%%g..   M1 2 2 2 2 2  r)ct}|||dtjd|||dS)zRelease a pay-as-you-go instance or an expired subscription instance. :param instance_id: The ID of the instance that you want to release. Tz%Delete %s command submit successfullyN)r r set_ForcerGrHr/)r#rQr3s r'delete_instancezAcsClient.delete_instanceZsd ()){+++$ rsW  SSSSSSSSWVVVVVTTTTTTMLLLLLTTTTTTVVVVVVXXXXXXVVVVVVSRRRRRUTTTTTRRRRRRTTTTTTRRRRRRTTTTTTRRRRRRbbbbbbbbbbr)