o eY@sdZddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddl m Z dd lmZdd lmZeeZejdd krSeefZneefZGd d d ejZdS)z. This module provides a client class for BES. N)bce_base_client)compat) bce_v1_signer)bce_http_client)handler) http_methods) bes_model)requiredc @seZdZdZdZd1ddZeeeeee eeeee j d d1ddZ eeeeeed  d1d d Z eeed  d1d dZeed d1ddZeed d1ddZeed d1ddZeed d1ddZeeed d1ddZeeed d1ddZeeeeeed d1ddZeeeed  d1d!d"Zeeeeeeeed# d1d$d%Z d1d&d'Zeeeeed( d1d)d*Zeed d1d+d,Zd1d-d.Z  d2d/d0ZdS)3 BesClientz Bes sdk client s/api/bes/clusterNcCstj||dSN)r BceBaseClient__init__)selfconfigrPD:\Projects\ConvertPro\env\Lib\site-packages\baidubce/services/bes/bes_client.pyr-szBesClient.__init__) namepasswordmodulesversionis_old_packageavailable_zonesecurity_group_id subnet_uuidvpc_idbillingc  Cs|d} d} | dur d| i} g}|D]}||jq||||||||| | jd }|jj}|dd}|jtj| | t||dS)aq Create cluster :param name: The parameter to specify es cluster name. :type name: string :param password: The parameter to specify password for manage cluster. :type password: string :param modules: The parameter to specify modules for cluster. :type modules: array :param version: The parameter to specify es cluster version. :type version: string :param is_old_package: The parameter to specify is old package :type is_old_package: bool :param available_zone: he parameter to specify security zone. :type available_zone: string :param security_group_id: The parameter to specify id of the securityGroup. :type security_group_id: string :param subnet_uuid: The parameter to specify id of the subnet. :type subnet_uuid: string :param vpc_id: The parameter to specify id of the vpc. :type vpc_id: string :param billing: The parameter to specify id of billing info. :type billing: xxx :return: :rtype baidubce.bce_response.BceResponse s/createN clientToken) rrrrZ isOldPackageZ availableZoneZsecurityGroupIdZ subnetUuidZvpcIdrapplication/json;charset=UTF-8sx-Regions content-typeparamsbodyheaders append__dict__rregion _send_requestrPOSTjsondumps)rrrrrrrrrrr client_tokenpathr!module_json_arraymoduler"r'r#rrrcreate_cluster0s0: zBesClient.create_cluster)r payment_type cluster_idr'rc Csdd}ddi}g} |D]} | | jq ||| ||d} |jj}|dd} |jtj||t| | dS)aT resize cluster :param name: The parameter to specify es cluster name. :type name: string :param payment_type: The parameter to specify mode of payment. :type payment_type: string :param cluster_id: The parameter to specify cluster id. :type cluster_id: array :param region: The parameter to specify region. :type region: string :param modules: The parameter to specify the type of es cluster node resource. :type modules: list :return: :rtype baidubce.bce_response.BceResponse s/resize orderTypeZRESIZE)rZ paymentTyper clusterIdr'rrr r$) rrr1r2r'rr,r-r!r.r/r"r#rrrresize_clusters"! zBesClient.resize_cluster)page_no page_sizec CPd}d}|dur d|i}||d}|jj}|dd}|jtj||t||dS)a1 get es cluster list :param page_no: The parameter to specify cluster list pageNo. :type page_no: int :param page_size: The parameter to specify cluster list pageSize. :type page_size: int :return: :rtype baidubce.bce_response.BceResponse s/listNr)pageNopageSizerrr rr'r(rr)r*r+) rr6r7r,r-r!r"r'r#rrrget_cluster_listszBesClient.get_cluster_list)r2cCNd}d}|dur d|i}d|i}|jj}|dd}|jtj||t||dS)z get cluster detail info :param cluster_id: The parameter to specify cluster id. :type cluster_id: string :return: :rtype baidubce.bce_response.BceResponse s/detailNrr4rrr r;rr2r,r-r!r"r'r#rrrget_cluster_detail zBesClient.get_cluster_detailcCr=)z start es cluster :param cluster_id: The parameter to specify cluster id. :type cluster_id: string :return: :rtype baidubce.bce_response.BceResponse s/startNrr4rrr r;r>rrr start_cluster r@zBesClient.start_clustercCr=)z stop es cluster :param cluster_id: The parameter to specify cluster id. :type cluster_id: string :return: :rtype baidubce.bce_response.BceResponse s/stopNrr4rrr r;r>rrr stop_cluster+r@zBesClient.stop_clustercCr=)z delete es cluster :param cluster_id: The parameter to specify cluster id. :type cluster_id: string :return: :rtype baidubce.bce_response.BceResponse s/deleteNrr4rrr r;r>rrrdelete_clusterKr@zBesClient.delete_cluster)r2 instance_idc Cr8)a7 start instance of es cluster :param cluster_id: The parameter to specify cluster id. :type cluster_id: string :param instance_id: The parameter to specify cluster id. :type instance_id: string :return: :rtype baidubce.bce_response.BceResponse s/instance/startNrr4Z instanceIdrrr r; rr2rDr,r-r!r"r'r#rrrstart_instancekzBesClient.start_instancec Cr8)a6 stop instance of es cluster :param cluster_id: The parameter to specify cluster id. :type cluster_id: string :param instance_id: The parameter to specify cluster id. :type instance_id: string :return: :rtype baidubce.bce_response.BceResponse s/instance/stopNrrErrr r;rFrrr stop_instancerHzBesClient.stop_instance)orderorder_byr6r7days_to_expirationc CsVd}d}|dur d|i}|||||d} |jj} | dd} |jtj||t| | dS)at get es cluster renew list :param order: The parameter to specify order rule. :type order: string :param order_by: The parameter to specify order field. :type order_by: string :param page_no: The parameter to specify renew cluster list pageNo. :type page_no: int :param page_size: The parameter to specify renew cluster list pageSize. :type page_size: int :param days_to_expiration: The parameter to specify how many days expire. :type days_to_expiration: int :return: :rtype baidubce.bce_response.BceResponse s /renew/listNr)r9r:ZdaysToExpirationrJZorderByrrr r;) rrJrKr6r7rLr,r-r!r"r'r#rrrget_renew_lists !zBesClient.get_renew_list)rJr2timec CsZd}d}ddi}|dur||d<d||d}|jj}|dd }|jtj||t||d S) a, renew es cluster :param cluster_id: The parameter to specify order cluster id. :type cluster_id: string :param time: The parameter to specify renew time, unit month. :type time: int :return: :rtype baidubce.bce_response.BceResponse s/renewNr3ZRENEWrBES) serviceTyperNr4rrr r;) rr2rNr,r-r!r"r'r#rrr renew_clusterszBesClient.renew_cluster) cluster_idsuser_idr'Z service_typeZ service_idsrenew_time_unit renew_timec CsXd}d}|dur d|i}|||d||d} |jj}|dd} |jtj||t| | dS) aT create cluster auto renew rule :param cluster_ids: The parameter to cluster id list. :type cluster_ids: list :param user_id: The parameter to specify account id. :type user_id: string :param region: The parameter to specify region. :type region: string :param renew_time_unit: The parameter to specify renew time unit. :type renew_time_unit: string :param renew_time: The parameter to specify renew time. :type renew_time: int :return: :rtype baidubce.bce_response.BceResponse s/auto_renew_rule/createNrrO)Z clusterIdsZuserIdr'rP renewTimeUnit renewTimerrr r;) rrRrSr'rTrUr,r-r!r"r#rrrcreate_auto_renew_rules"#z BesClient.create_auto_renew_rulecCsNd}d}|dur d|i}ddi}|jj}|dd}|jtj||t||dS) zu get cluster auto renew rule list :return: :rtype baidubce.bce_response.BceResponse s/auto_renew_rule/listNrrPrOrrr r;)rr,r-r!r"r'r#rrrget_auto_renew_rule_listFsz"BesClient.get_auto_renew_rule_list)r2Z account_idrTrUc CsRd}d}|dur d|i}|||d}|jj}|dd} |jtj||t|| dS)a update cluster auto renew rule :param cluster_id: The parameter to cluster id list. :type cluster_id: string :param renew_time_unit: The parameter to specify renew time unit. :type renew_time_unit: string :param renew_time: The parameter to specify renew time. :type renew_time: int :return: :rtype baidubce.bce_response.BceResponse s/auto_renew_rule/updateNr)r4rVrWrrr r;) rr2rTrUr,r-r!r"r'r#rrrupdate_auto_renew_rule\sz BesClient.update_auto_renew_rulecCr=)z delete cluster auto renew rule :param cluster_id: The parameter to cluster id list. :type cluster_id: string :return: :rtype baidubce.bce_response.BceResponse s/auto_renew_rule/deleteNrr4rrr r;r>rrrdelete_auto_renew_rules z BesClient.delete_auto_renew_rulecCs(|dur|jSt|j}|||Sr )rcopyZmerge_non_none_values)rrZ new_configrrr _merge_configs   zBesClient._merge_configc CsL||}|dur tj}t|j|_t|tj tj |g|t j ||||Sr ) r]rZ parse_jsonrZconvert_to_bytesZendpointr send_requestrsignZ parse_errorr prefix)rZ http_methodr-r"r#r!rZ body_parserrrrr(s zBesClient._send_requestr )NNNNN)__name__ __module__ __qualname____doc__r`rr value_typelistboolrZBillingr0r5intr<r?rArBrCrGrIrMrQrXrYrZr[r]r(rrrrr 's  O 8 #     $ $ / ! 1  $  r )rdr\r*loggingsysZbaidubcerrZ baidubce.authrZ baidubce.httprrrZbaidubce.services.besrZbaidubce.utilsr getLoggerraZ_logger version_infostrunicoderebytesr r rrrrs$