(dZddlmZddlmZddlmZddlZddlmZddlmZddl m Z dd l m Z dd l m Z dd lmZdd lmZe j"e j$e j&j(e j&j*Gd de j,Ze j$e j&j0GddeZy)z"bigtable instances create command.)absolute_import)division)unicode_literalsN)clusters)util)base) exceptions) arguments)log) resourcescveZdZdZdZdej diZedZ dZ dZ dZ d Z ed d Zy ) CreateInstanceCreate a new Bigtable instance.FEXAMPLESa To create an instance with id `my-instance-id` with a cluster located in `us-east1-c`, run: $ {command} my-instance-id --display-name="My Instance" --cluster-config=id=my-cluster-id,zone=us-east1-c To create an instance with multiple clusters, run: $ {command} my-instance-id --display-name="My Instance" --cluster-config=id=my-cluster-id-1,zone=us-east1-c --cluster-config=id=my-cluster-id-2,zone=us-west1-c,nodes=3 To create an instance with `HDD` storage and `10` nodes, run: $ {command} my-hdd-instance --display-name="HDD Instance" --cluster-storage-type=HDD --cluster-config=id=my-cluster-id,zone=us-east1-c,nodes=10 ctj|jdjj j j jjj|jr#tj|jtj|dd|jjtjy)z Register flags for this command.T)requiredz to create) positionalN)r ArgAdderAddInstanceDisplayNameAddClusterConfigAddDeprecatedClusterAddDeprecatedClusterZoneAddDeprecatedClusterNodesAddClusterStorageAddAsyncAddDeprecatedInstanceType _support_tagsAddTagsAddInstanceResourceArg display_infoAddCacheUpdaterInstanceCompleter)clsparsers (lib/surface/bigtable/instances/create.pyArgszCreateInstance.Args9s 6"    .       ! ! # " " $     " " $  ((* $$V[TJ '' (C(CDc$|j|S)zExecutes the instances create command. Args: args: an argparse namespace. All the arguments that were provided to this command invocation. Returns: Some value that we want to have printed later. )_Run)selfargss r%RunzCreateInstance.RunNs 99T?r'c btj}|jjj }t j jd|j}tj}|jj|j}|j|}g}t|jD];\} } |j!|j"j$j'| | =|j#|j)|j+|j|j,||j/||j"j%|} |j0j| } tj2| } |j4rEt7j8| j+dj;|j)d | Stj<| d j;|j)S) z8Implements Run() with different possible features flags.zbigtableadmin.projects) projectIdkeyvalue) displayNametypetagsadditionalProperties) instanceIdparentinstancerzbigtable instance {0}T)kindis_asynczCreating bigtable instance {0})rGetAdminClientCONCEPTSr9Parser REGISTRYCreate projectsIdGetAdminMessagesInstanceTypeValueValuesEnum instance_type _ClusterssorteditemsappendCreateInstanceRequest ClustersValueAdditionalPropertyName RelativeName display_name_Tagsprojects_instancesGetOperationRefasync_r CreatedResourceformat AwaitInstance)r*r+cliref parent_refmsgsrE new_clustersclusters_properties cluster_idclustermsgresult operation_refs r%r)zCreateInstance._Run[s    C -- & & (C##** CNN+>$'L%l&8&8&:; G   $ $ 2 2 E EG F -. <  $ $88:&&())D! ++99!4:  % C # # * *3 /F((0M {{   $ $ &&--chhj9m   7>>sxxzJ LLr'c tj}|jj|jj }|j \|j|j |jtjdd|j|j i}|j D]}|jdd}|jd|jj|jjj}|j|||tj |d}d |vr|j#|d  |_d |vsd |vsd |vr:d|vr|d} nd} t'j(|d |d |d | |_d|_|||d<|S|j|jtjdd|jt/j0|||jj|jjjtj |j}|j|iStjdd)zGet the clusters configs from command arguments. Args: args: the argparse namespace from Run(). Returns: A dict mapping from cluster id to msg.Cluster. Nz=--cluster-config --cluster --cluster-zone --cluster-num-nodesz}Use --cluster-config or the combination of --cluster, --cluster-zone and --cluster-num-nodes to specify cluster(s), not both.nodesznode-scaling-factorzone) serveNodesnodeScalingFactordefaultStorageTypelocationzkms-key) kmsKeyNameautoscaling-min-nodesautoscaling-max-nodesautoscaling-cpu-targetautoscaling-storage-target)autoscaling_minautoscaling_maxautoscaling_cpu_targetautoscaling_storage_targetidz--cluster-zonez!--cluster-zone must be specified.)rfrhrgriz--cluster --cluster-configz+Use --cluster-config to specify cluster(s).)rrBCluster!DefaultStorageTypeValueValuesEnumcluster_storage_typeuppercluster_configr^ cluster_zonecluster_num_nodesr InvalidArgumentException_ValidateClusterConfigArgsget NodeScalingFactorValueValuesEnumNODE_SCALING_FACTOR_1X LocationUrlEncryptionConfigencryptionConfigrBuildClusterConfig clusterConfigrfr ProcessInstanceTypeAndNodes) r*r+rZ storage_typer[ cluster_dictrcnode_scaling_factorr^storage_targets r%rFzCreateInstance._Clusterss  "D<<AA !!'')+L & ,, "    *  # # /11 K    %%d&9&9:l--,  !,*.. ! LL 9 9 ==TT   ,,1+%%l6&:; =  $%)%:%:%i0&;&2' " $| 3 #| 3 $ 4 )\ 9)*FGN!N"*"="=*+BC*+BC%12J%K)7 #9'  $' +2 \$'(K.L  !   "11 AC C ::4@) LLIIll;;RR ##D$5$56 8gllG $$  / / & 7 r'c|D]O}d|vs d|vs d|vsd|vsd|vrtjddd|vs d|vsd|vs;tjdd y ) z9Validates arguments in cluster-config as a repeated dict.rkrlrmrnrcze--autoscaling-min-nodes --autoscaling-max-nodes --autoscaling-cpu-target --autoscaling-storage-targetzAt most one of nodes | autoscaling-min-nodes autoscaling-max-nodes autoscaling-cpu-target autoscaling-storage-target may be specified in --cluster-configzH--autoscaling-min-nodes --autoscaling-max-nodes --autoscaling-cpu-targetzrAll of --autoscaling-min-nodes --autoscaling-max-nodes --autoscaling-cpu-target must be set to enable Autoscaling.N)r r{)r*rxrs r%r|z)CreateInstance._ValidateClusterConfigArgss' !\ 1 !\ 1 "l 2 &, 6 l "33FPQ Q $< 7 #< 7 $L 833)+$% %#'r'c |jsyt||}|sytjjj }|t |jDcgc]\}}|j||c}}Scc}}w)zGet the tags from command arguments. Args: args: the argparse namespace from Run(). tags_arg_name: the name of the tags argument. Returns: A dict mapping from tag key to tag value. Nr/r5) rgetattrrrBrC TagsValuerGrHrL)r#r+ tags_arg_namer4 tags_messager0r1s r%rPzCreateInstance._Tagss     4 'D  ((*33==L %TZZ\2 2 U  + +5 + A2   s#B N)r4)__name__ __module__ __qualname____doc__rtextwrapdedent detailed_help classmethodr&r,r)rFr|rPr'r%rr sl(-/(//#-$EE( )LVTl%4r'rceZdZdZdZy)CreateInstanceAlpharTN)rrrrrrr'r%rrs '-r'r)r __future__rrrrgooglecloudsdk.api_lib.bigtablerrgooglecloudsdk.callioperr #googlecloudsdk.command_lib.bigtabler googlecloudsdk.corer r UniverseCompatible ReleaseTracks ReleaseTrackGABETA CreateCommandrALPHArrr'r%rs)&'40(.9#)D%%(($*;*;*@*@AnT''nBnbD%%++,.-r'