
    
                         S r SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJ	r	  SSK
Jr  SS	KJr  SS
KJr  \R                    " S S\R"                  5      5       rg)z$The gcloud firestore import command.    )absolute_import)division)unicode_literals)importexport)
operations)storage_util)base)flags)
propertiesc                   6    \ rS rSrSrSS0r\S 5       rS rSr	g)	Import   z;import Cloud Firestore documents from Google Cloud Storage.EXAMPLESa            To import all collection groups from `mybucket/my/path`, run:

            $ {command} gs://mybucket/my/path

          To import a specific set of collections groups asynchronously, run:

            $ {command} gs://mybucket/my/path --collection-ids='specific collection group1','specific collection group2' --async

          To import all collection groups from certain namespace, run:

            $ {command} gs://mybucket/my/path --namespace-ids='specific namespace id'
      c                     [         R                  " U 5        [         R                  " U 5        [         R                  " U 5        U R	                  SSS9  [
        R                  R                  U 5        g)z Register flags for this command.INPUT_URI_PREFIXz
        Location of the import files.

        This location is the 'output_uri_prefix' field of a previous export,
        and can be found via the '{parent_command} operations describe' command.
        )helpN)r
   AddCollectionGroupIdsFlagAddNamespaceIdsFlagAddDatabaseIdFlagadd_argumentr	   
ASYNC_FLAGAddToParser)parsers    lib/surface/firestore/import.pyArgsImport.Args2   s]     
##F+	f%	F#
   	OO'    c                    [         R                  R                  R                  R	                  SS9n[
        R                  R                  UR                  SS9n[        R                  " UUR                  UR                  5       R                  S5      UR                  UR                  S9nUR                   (       d  ["        R$                  " U5        U$ )NT)required)allow_empty_object/)namespace_idscollection_ids)r   VALUEScoreprojectGetr   ObjectReferenceFromUrlr   r   r   databaseToUrlrstripr"   r#   async_r   WaitForOperation)selfargsr&   
object_refresponses        r   Run
Import.RunB   s    $$,,00$0?G--55$ 6 8J ""!!#&((**,H ;;!!(+Or    N)
__name__
__module____qualname____firstlineno____doc__detailed_helpstaticmethodr   r3   __static_attributes__r5   r   r   r   r      s/    C 
-" ( (r   r   N)r:   
__future__r   r   r    googlecloudsdk.api_lib.firestorer   r   googlecloudsdk.api_lib.storager   googlecloudsdk.callioper	   $googlecloudsdk.command_lib.firestorer
   googlecloudsdk.corer   DefaultUniverseOnlyCommandr   r5   r   r   <module>rF      sJ    + &  ' 9 7 7 ( 6 * 3T\\ 3 3r   