o $ºiwHã@s:ddlZddlZddlmZddlmZmZddlmZddl 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/m0Z0Gdd„dƒZ1dS)éN)Úclient)ÚClientExceptionÚServerException)ÚAllocatePublicIpAddressRequest)ÚAuthorizeSecurityGroupRequest)ÚCreateInstanceRequest)ÚCreateKeyPairRequest)ÚCreateSecurityGroupRequest)ÚCreateVpcRequest)ÚCreateVSwitchRequest)ÚDeleteInstanceRequest)ÚDeleteInstancesRequest)ÚDeleteKeyPairsRequest)ÚDescribeInstancesRequest)ÚDescribeKeyPairsRequest)ÚDescribeSecurityGroupsRequest)ÚDescribeVpcsRequest)ÚDescribeVSwitchesRequest)ÚImportKeyPairRequest)ÚRunInstancesRequest)ÚStartInstanceRequest)ÚStopInstanceRequest)ÚStopInstancesRequest)ÚTagResourcesRequestc@sðeZdZdZdd„Zd:dd„Z   d;d d „Z    dd#d$„Zd?d&d'„Zd(d)„Zd*d+„Zd,d-„Zd.d/„Zd0d1„Zd2d3„Zd@d4d5„Zd@d6d7„Zd8d9„ZdS)AÚ 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. cCstj||||d|_dS)N)ÚakÚsecretÚmax_retry_timeÚ region_id)rrÚcli)ÚselfÚ access_keyÚaccess_key_secretrÚ max_retries©r$úa/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/ray/autoscaler/_private/aliyun/utils.pyÚ__init__8s  üzAcsClient.__init__NcCsTtƒ}|dur | |¡|dur| |¡| |¡}|dur(| d¡ d¡}|SdS)zÛQuery 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Ú InstancesÚInstance)rÚset_TagsÚset_InstanceIdsÚ _send_requestÚget)r ÚtagsÚ instance_idsÚrequestÚresponseÚ instance_listr$r$r%Údescribe_instances@s   zAcsClient.describe_instancesÚ optimizedÚPostPaidÚSpotWithPriceLimitÚ PayByTrafficéc Csštƒ} |  |¡|  |¡|  |¡|  |¡|  |¡|  |¡|  | ¡|  |¡|   |¡|  | ¡} | durF|   d¡} t   d| ¡| St  d¡dS)aéCreate 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.)rÚset_InstanceTypeÚ set_ImageIdÚset_IoOptimizedÚset_InstanceChargeTypeÚset_SpotStrategyÚset_InternetChargeTypeÚset_InternetMaxBandwidthOutÚset_KeyPairNamer)r+r,ÚloggingÚinfoÚerror) r Ú instance_typeÚimage_idr-Ú key_pair_namer3Úinstance_charge_typeÚ spot_strategyÚinternet_charge_typeÚinternet_max_bandwidth_outr/r0Ú instance_idr$r$r%Úcreate_instanceRs"             zAcsClient.create_instanceéc Cs²tƒ} |  |¡|  |¡|  |¡|  | ¡|  | ¡|  | ¡|  | ¡|  |¡|   |¡|   |¡|   |¡|   |¡|  | ¡}|durR| d¡ d¡}|St d¡dS)aÜCreate 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. NÚInstanceIdSetsÚ InstanceIdSetr9)rr:r;r<r=r>r?r@r)Ú set_AmountÚset_SecurityGroupIdÚ set_VSwitchIdrAr+r,rBrD)r rErFr-Úsecurity_group_idÚ vswitch_idrGÚamountr3rHrIrJrKr/r0r.r$r$r%Ú run_instancesƒs&)              zAcsClient.run_instancescCs4tƒ}| |¡| |¡}|dur| d¡}|SdS)z¸Create a security group :param vpc_id: The ID of the VPC in which to create the security group. :return: The created security group ID. NÚSecurityGroupId)r Ú set_VpcIdr+r,)r Úvpc_idr/r0rTr$r$r%Úcreate_security_groupÁs   zAcsClient.create_security_groupcCs^tƒ}|dur | |¡|dur| |¡| |¡}|dur(| d¡ d¡}|St d¡dS)zÞQuery 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. NÚSecurityGroupsÚ SecurityGroupzdescribe security group failed.)rrYr)r+r,rBrD)r rZr-r/r0Úsecurity_groupsr$r$r%Údescribe_security_groupsÐs    z"AcsClient.describe_security_groupscCs<tƒ}| |¡| |¡| |¡| |¡| |¡dS)aÅCreate 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)rÚset_IpProtocolÚ set_PortRangerRÚset_SourceCidrIpr+)r Ú ip_protocolÚ port_rangerTÚsource_cidr_ipr/r$r$r%Úauthorize_security_groupãs     z"AcsClient.authorize_security_groupcCsPtƒ}| |¡| |¡| |¡| |¡}|dur | d¡St d|¡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_ZoneIdrYÚ set_CidrBlockr+r,rBrD)r rZÚzone_idÚ cidr_blockr/r0r$r$r%Úcreate_v_switchös      zAcsClient.create_v_switchcCs&tƒ}| |¡}|dur| d¡SdS)zUCreates a virtual private cloud (VPC). :return: The created VPC ID. NÚVpcId)r r+r,©r r/r0r$r$r%Ú create_vpc s   zAcsClient.create_vpccCs,tƒ}| |¡}|dur| d¡ d¡SdS)zJQueries one or more VPCs in a region. :return: VPC list. NÚVpcsÚVpc)rr+r,rnr$r$r%Ú describe_vpcss  zAcsClient.describe_vpcsÚinstancecCsVtƒ}| |¡| |¡| |¡| |¡}|dur#t d|¡dSt d|¡dS)zÖCreate 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_ResourceTypeÚset_ResourceIdsr+rBrCrD)r Ú resource_idsr-Ú resource_typer/r0r$r$r%Ú tag_resource s    zAcsClient.tag_resourcecCsBtƒ}| |¡| |¡}|durt d|¡dSt d|¡dS)zQStart an ECS instance. :param instance_id: The Ecs instance ID. Nzinstance %s start successfully.zinstance %s start failed.)rÚset_InstanceIdr+rBrCrD©r rLr/r0r$r$r%Ústart_instance1s   zAcsClient.start_instanceFcCs4tƒ}| |¡| |¡t d|¡| |¡dS)zÊStop 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)rryÚ set_ForceStoprBrCr+)r rLÚ force_stopr/r$r$r%Ú stop_instance?s    zAcsClient.stop_instanceÚ StopChargingcCs>tƒ}| |¡| |¡| |¡}|durt d¡dSdS)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+rBrD)r r.Ú stopped_moder/r0r$r$r%Ústop_instancesLs   ÿzAcsClient.stop_instancescCs4tƒ}| |¡| d¡t d|¡| |¡dS)z¨Release 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 ryÚ set_ForcerBrCr+)r rLr/r$r$r%Údelete_instanceZs    zAcsClient.delete_instancecCs(tƒ}| d¡| |¡| |¡dS)z°Release one or more pay-as-you-go instances or expired subscription instances. :param instance_ids: The IDs of instances that you want to release. TN)r rƒr*r+)r r.r/r$r$r%Údelete_instancesfs  zAcsClient.delete_instancescCs0tƒ}| |¡| |¡}|dur| d¡SdS)zÚAssign a public IP address to an ECS instance. :param instance_id: The ID of the instance to which you want to assign a public IP address. :return: The assigned ip. NÚ IpAddress)rryr+r,rzr$r$r%Úallocate_public_addressqs    ÿz!AcsClient.allocate_public_addresscCsFtƒ}| |¡| |¡}|durt d| d¡¡|St d¡dS)z„Create an SSH key pair. :param key_pair_name: The name of the key pair. :return: The created keypair data. NzCreate Key Pair %s SuccessfullyÚ KeyPairIdzCreate Key Pair Failed)rrAr+rBrCr,rD©r rGr/r0r$r$r%Úcreate_key_pair~s   zAcsClient.create_key_paircCs(tƒ}| |¡| |¡| |¡dS)zéImport the public key of an RSA-encrypted key pair that is generated by a third-party tool. :param key_pair_name: The name of the key pair. :param public_key_body: The public key of the key pair. N)rrAÚset_PublicKeyBodyr+)r rGÚpublic_key_bodyr/r$r$r%Úimport_key_pairŽs  zAcsClient.import_key_paircCstƒ}| |¡| |¡dS)zuDelete one or more SSH key pairs. :param key_pair_names: The name of the key pair. :return: N)rÚset_KeyPairNamesr+)r Úkey_pair_namesr/r$r$r%Údelete_key_pairsšs zAcsClient.delete_key_pairscCs>tƒ}|dur | |¡| |¡}|dur| d¡ d¡SdS)zoQuery one or more key pairs. :param key_pair_name: The name of the key pair. :return: NÚKeyPairsÚKeyPair)rrAr+r,r‰r$r$r%Údescribe_key_pairs¤s  zAcsClient.describe_key_pairscCsHtƒ}|dur | |¡| |¡}|dur| d¡ d¡St d¡dS)zŽQueries one or more VSwitches. :param vpc_id: The ID of the VPC to which the VSwitch belongs. :return: VSwitch list. NÚ VSwitchesÚVSwitchzDescribe VSwitches Failed.)rrYr+r,rBrD)r rZr/r0r$r$r%Údescribe_v_switches³s   zAcsClient.describe_v_switchesc Csj| d¡z|j |¡}t |¡}|WSttfy4}zt |  ¡¡t |¡WYd}~dSd}~ww)zsend open api requestÚjsonN) Úset_accept_formatrÚdo_action_with_exceptionr—ÚloadsrrrBrDÚget_action_name)r r/Ú response_strÚresponse_detailÚer$r$r%r+Ãs    €ýzAcsClient._send_request)NN)r3r4r5r6r7)rNr3r4r5r6rN)rs)F)r)N)Ú__name__Ú __module__Ú __qualname__Ú__doc__r&r2rMrWr[r_rfrlrorrrxr{r~r‚r„r…r‡rŠrrr“r–r+r$r$r$r%r+sH  ö9 ó>         r)2r—rBÚ aliyunsdkcorerÚ&aliyunsdkcore.acs_exception.exceptionsrrÚ=aliyunsdkecs.request.v20140526.AllocatePublicIpAddressRequestrÚs4