o #jV@szdZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z ddl mZddlmZGdd d ejZdS) z- This module provides a client class for AS. N)bce_base_clientcompat) bce_v1_signer)handlerbce_http_client http_methods) as_handler)requiredc @sFeZdZdZdZdZdZdZd;ddZd;d d Z dddZeeedddZeeeeeeeed   d?dd Zeeeeeeeeed!   d?d"d#Zeed$d%d&Zeed' d@d*d+ZdAd,d-Z . dBd/d0Zd1d2Zd;d3d4Zd5d6Zd7d8Zd9d:ZdS)CAsClientz AS base sdk client s/v1s content-typesapplication/json;charset=UTF-8sx-bce-request-idNcCstj||dSN)r BceBaseClient__init__)selfconfigrh/var/www/html/Deteccion_Ine/venv/lib/python3.10/site-packages/baidubce/services/autoscaling/as_client.pyr szAsClient.__init__cCs(|dur|jSt|j}|||Sr )rcopyZmerge_non_none_values)rrZ new_configrrr _merge_configs   zAsClient._merge_configc Csx||}|dur tj}|duri}|j|vr|j||j<|j|vr)t||j<t |t j t j |g|tj||||Sr )rrZ parse_jsoncontent_type_header_keycontent_type_header_valuerequest_id_header_keyuuiduuid4r send_requestrsignrZ parse_errorr version)rZ http_methodpathbodyheadersparamsrZ body_parserrrr _send_request$s    zAsClient._send_requestc Cs(||||||d}d}|jtj||dS)af Get autoscaling group list :param page_no: page_no :type page_no: int :param keyword: query keyword :type keyword: string :param keyword_type: query keyword type :type keyword_type: string :param order: order-ascending order or descending order :type order: string :param order_by: order by param :type order_by: :return: :rtype baidubce.bce_response.BceResponse )keyword keywordTypeorderorderBypageNopageSize/grouprr rGET) rpage_no page_sizekeyword keyword_typeorderorder_byrrrrrget_as_group_list4szAsClient.get_as_group_listcCs4t|dkr tdt|}d|}|tj|S)z Get autoscaling group detail :param group_id: autoscaling group_id :type group_id: string :return: :rtype baidubce.bce_response.BceResponse r+group_id should not be none or empty string /group/%s)len ValueErrorrconvert_to_bytesr rr,)rgroup_idrrrrget_as_group_detailYs  zAsClient.get_as_group_detailc Cs>t|dkr td|||||||d}d} |jtj| |dS)a Get autoscaling group node list :param group_id: autoscaling group_id :type group_id: string :param page_no: page_no :type page_no: int :param keyword: query keyword :type keyword: string :param keyword_type: query keyword type :type keyword_type: string :param order: order-ascending order or descending order :type order: string :param order_by: order by param :type order_by: :return: :rtype baidubce.bce_response.BceResponse rr4)groupidr#r$r%r&r'r(s/noder*)r6r7r rr,) rr9r-r.r/r0r1r2rrrrrget_as_group_node_lisths  zAsClient.get_as_group_node_listcCs8t|dkr tdd}d|i}|jtj|t|dS)z Get autoscaling group node list :param group_ids: autoscaling group_ids :type group_ids: list of strings rr4s /group/deletegroupIdsr)r6r7r rPOSTjsondumps)r group_idsrrrrr delete_groups zAsClient.delete_groupcCs>d}||||||||| | | | | |d}|jtj|t|dS)a[ Create autoscaling group :param group_name: autoscaling group_name :type group_name: string :param config: autoscaling group config :type config: dict :param health_check: autoscaling group health check info :type health_check: dict :param blb: blb info :type blb: list of strings :param rds: rds info :type rds: list of strings :param scs: scs info :type scs: list of strings :param shrinkage_strategy: autoscaling group shrinkage strategy :type shrinkage_strategy: string :param zone_info: autoscaling group zone info :type zone_info: dict :param assign_tag_info: autoscaling group tag info :type assign_tag_info: dict :param nodes: autoscaling group nodes :type nodes: dict :param eip: autoscaling group eip info :type eip: dict :param billing: autoscaling group billing info :type billing: dict :param cmd_config: autoscaling group cmd config :type cmd_config: dict :param bcc_name_config: autoscaling group bcc name config :type bcc_name_config: dict :return: :rtype baidubce.bce_response.BceResponse r))Z groupNamerZ healthCheckblbrdsscsZshrinkageStrategyZzoneInfoZ assignTagInfonodeseipbillingZ cmdConfigZ bccNameConfigr>r rr?r@rA)r group_namerZ health_checkrDrErFZshrinkage_strategyZ zone_infosZassign_tag_infoZ node_listrHrIZ cmd_configZbcc_name_configrrrrr create_groups"BzAsClient.create_group)r9rGcCs8dt|}ddi}d|i}|jtj|t||dS)z Detach nodes from group :param group_id: the id of group :type group_id: string :param nodes: the list of node :type nodes: list :return: the result of detach node :rtype: dict r5Z detachNoderG)rrrr8r rr?r@rArr9rGrrrrrr detach_nodes  zAsClient.detach_node) rule_namer9state rule_type action_type action_numcooldown_in_secrM0cCsd}id|d|d|d|d|d| d| d | d | d | d |d |d|d|d|d|d|d|i}|jtj|t|dS)a Create rule :param rule_name: the name of the rule :type rule_name: string :param group_id: the id of the group :type group_id: string :param state: the state of the rule, can be "ENABLE" or "DISABLE" :type state: string :param rule_type: the type of the rule, can be "ALARM", "CRONTAB", or "PERIOD" :type rule_type: string :param target_type: the type of the target :type target_type: string :param target_id: the id of the target :type target_id: string :param indicator: the indicator of the rule :type indicator: string :param threshold: the threshold of the rule :type threshold: string :param unit: the unit of the threshold :type unit: string :param comparison_operator: the comparison operator of the rule :type comparison_operator: string :param action_type: the action type of the rule, can be INCREASE, DECREASE, ADJUST :type action_type: string :param action_num: the number of actions to be performed :type action_num: int :param cron_time: the cron time of the rule :type cron_time: string :param cooldown_in_sec: the cooldown time in seconds :type cooldown_in_sec: int :param period_type: the period type of the rule :type period_type: string :param period_value: the period value of the rule :type period_value: int :param period_start_time: the start time of the period :type period_start_time: string :param period_end_time: the end time of the period :type period_end_time: string /ruleruleNamegroupIdrRtype targetTypetargetId indicator thresholdunitcomparisonOperator actionType actionNumcronTime cooldownInSec periodType periodValueperiodStartTime periodEndTimer>rJ)rrQr9rRrSrTrUrV target_type target_idr^r_r`comparison_operator cron_time period_type period_valueperiod_start_timeperiod_end_timerrrrr create_rulesN.     zAsClient.create_rule)rule_idrQr9rRrSrTrUrVcCsdt|}id|d|d|d|d| d| d| d | d | d |d |d |d|d|d|d|d|d|i}|jtj|t|dS)a Update rule :param rule_id: the id of the rule :type rule_id: string :param rule_name: the name of the rule :type rule_name: string :param group_id: the id of the group :type group_id: string :param state: the state of the rule, can be "ENABLE" or "DISABLE" :type state: string :param rule_type: the type of the rule, can be "ALARM", "CRONTAB", or "PERIOD" :type rule_type: string :param target_type: the type of the target :type target_type: string :param target_id: the id of the target :type target_id: string :param indicator: the indicator of the rule :type indicator: string :param threshold: the threshold of the rule :type threshold: string :param unit: the unit of the threshold :type unit: string :param comparison_operator: the comparison operator of the rule :type comparison_operator: string :param action_type: the action type of the rule, can be INCREASE, DECREASE, ADJUST :type action_type: string :param action_num: the number of actions to be performed :type action_num: int :param cron_time: the cron time of the rule :type cron_time: string :param cooldown_in_sec: the cooldown time in seconds :type cooldown_in_sec: int :param period_type: the period type of the rule :type period_type: string :param period_value: the period value of the rule :type period_value: int :param period_start_time: the start time of the period :type period_start_time: string :param period_end_time: the end time of the period :type period_end_time: string /rule/%srYrZrRr[r\r]r^r_r`rarbrcrdrerfrgrhrir>)rr8r rPUTr@rA)rrsrQr9rRrSrTrUrVrjrkr^r_r`rlrmrnrorprqrrrrr update_ruleTsN/     zAsClient.update_rule)rscCsdt|}|tj|S)z Get rule :param rule_id: the id of the rule :type rule_id: string :return: the result of get rule :rtype: dict rt)rr8r rr,)rrsrrrrget_rules zAsClient.get_rule)r9desc createTimec Cs*d}|||||||d} |jtj|| dS)a4 Query rule list :param group_id: the id of the group :type group_id: string :param keyword: the keyword of the rule :type keyword: string :param keyword_type: the type of the keyword :type keyword_type: string :param order: the order of the rule :type order: string :param order_by: the order by of the rule :type order_by: string :param page_no: the page number :type page_no: int :param page_size: the page size :type page_size: int rX)Zgroupidr/Z keywordTyper1ZorderByZpageNoZpageSizer*r+) rr9r/r0r1r2r-r.rrrrr list_rules zAsClient.list_rulecCs@|s|stdd}ddi}||d}|jtj||t|dS)z Delete rule :param rule_ids: the list of rule id :type rule_ids: list :param group_ids: the list of group id :type group_ids: list z8rule_ids and group_ids can not be empty at the same timerXdeleterM)ZruleIdsr=rr)r7r rr?r@rA)rZrule_idsrBrrrrrr delete_ruleszAsClient.delete_rule startTimec Cs*|||||||d}d} |jtj| |dS)a@ Get details of a specific group :param group_id: Group identifier :type group_id: str :param page_no: Page number :type page_no: int :param page_size: Page size :type page_size: int :param order: Order-ascending order or descending order :type order: string :param order_by: Order by parameter :type order_by: string :param start_time: Start time for filtering the results :type start_time: string :param end_time: End time for filtering the results :type end_time: string :return: rtype baidubce.bce_response.BceResponse )r;r%r&r'r(s startTimesendTimes/recordr*r+) rr9r-r.r1r2 start_timeZend_timerrrrr get_recordss$ zAsClient.get_recordscC<t|}d|}ddi}d|i}|jtj||t|dS)aI Execute a specific rule within a group :param group_id: Group identifier :type group_id: str :param rule_id: Rule identifier within the group :type rule_id: str :return: rtype baidubce.bce_response.BceResponse r5sexecRulerMZruleIdr|rN)rr9rsrrrrrr exec_rule  zAsClient.exec_rulecCs@t|}d|}ddi}|||d}|jtj||t|dS)aK Scale up a specific group :param group_id: Group identifier :type group_id: str :param node_count: Number of nodes to be added :type node_count: int :param zone: Zone where the nodes will be added :type zone: str :param expansion_strategy: Strategy to be used for the expansion, optional :type expansion_strategy: str, optional :return: rtype baidubce.bce_response.BceResponse r5s scalingUprM)Z nodeCountzoneZexpansionStrategyr|rN)rr9Z node_countrZexpansion_strategyrrrrrr scaling_up"s zAsClient.scaling_upcCr)a> Scale down a specific group :param group_id: Group identifier :type group_id: str :param nodes: Nodes to be removed :type nodes: list or str :return: rtype baidubce.bce_response.BceResponse r5s scalingDownrMrGr|rNrOrrr scaling_downErzAsClient.scaling_downcCr)a Adjust the number of nodes in a specific group :param group_id: Group identifier :type group_id: str :param adjust_num: Number to adjust the nodes by. This could be positive (for adding nodes) or negative (for removing nodes). :type adjust_num: int :return: rtype baidubce.bce_response.BceResponse r5s adjustNoderMZ adjustNumr|rN)rr9Z adjust_numrrrrrr adjust_node^s zAsClient.adjust_nodecCr)a Attach nodes to a specific group. :param group_id: str The unique identifier of the group to which the nodes will be attached. :param nodes: list or str The nodes that will be attached to the group. This can be a list of node identifiers or a single node identifier. :return: baidubce.bce_response.BceResponse rtype baidubce.bce_response.BceResponse r5s attachNoderMrGr|rNrOrrr attach_nodexs zAsClient.attach_noder )NNNNN)r!r"NNNN)NNNNNNNNNNNNNN) rMrMrMrWrMrMrMNNNN)rMrMrxryr!r")NN)r!r"Nr~NN) __name__ __module__ __qualname____doc__rrrrr rr r3r:r<rCrLr strlistrPintrrrvrwrzr}rrrrrrrrrrr sf   % . U  C D    / # r )rrr@rZbaidubcerrZ baidubce.authrZ baidubce.httprrrZbaidubce.services.autoscalingrZbaidubce.utilsr r r rrrrs