SrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSK J r SSK J r SS K Jr SSK Jr SS KJr SS KJr SS KJr SS KJr SSKJr SrSrSSjrSSjr"SS\R:5rg)z$Command for spanner samples backend.)absolute_import)division)unicode_literalsN) exceptions) databases) arg_parsers)base)samples)execution_utils) properties) resources)initc$SRU5$)N{}-backend.log)formatappnames &lib/surface/spanner/samples/backend.py_get_logfile_namer$s   ))cU[R;a[SRU55e[R R [R"U5[RUR5$)NzUnknown sample app '{}') r APPS ValueErrorrospathjoinget_local_bin_path backend_binrs r_get_popen_jarr(s[ GLL .55g> ??    )7<<+@+L+L NNrcTUc[R"U5nSRU5SRU5SRU5/nUb URSRU55 [R"U5[ R :XaURS5 U$)z&Get formatted args for server command.z--spanner_project_id={}z--spanner_instance_id={}z--spanner_database_id={}z --port={}z--spanner_use_pg)r get_db_id_for_apprappendget_database_dialectrDATABASE_DIALECT_POSTGRESQL)projectr instance_id database_idportflagss r_get_popen_argsr*2s++G4K&&w/ '' 4 '' 4 %   LL##D)* !! 778 LL#$ ,rc .SS/nUR[U55 UR[XX#U55 U(a=[R R [RSRU55OSn[R"Xg5$)aRun the backend service executable for the given sample app. Args: project: str, Name of the GCP project. appname: str, Name of the sample app. instance_id: str, Cloud Spanner instance ID. database_id: str, Cloud Spanner database ID. port: int, Port to run the service on. capture_logs: bool, Whether to save logs to disk or print to stdout. Returns: subprocess.Popen or execution_utils.SubprocessTimeoutWrapper, The running subprocess. javaz-jarrN) r"rextendr*rrrr SAMPLES_LOG_PATHrrun_proc)r%rr&r'r( capture_logs proc_argscapture_logs_fns r run_backendr3Cs(v) >'*+ g $GI  ggll7++-=-D-DW-MN   ) 55rcV\rSrSrSrS\R "S50r\S5r Sr Sr g) BackendaaRun the backend gRPC service for the given Cloud Spanner sample app. This command starts the backend gRPC service for the given sample application. Before starting the service, create the database and load any initial data with: $ {parent_command} init APPNAME --instance-id=INSTANCE_ID After starting the service, generate traffic with: $ {parent_command} workload APPNAME To run all three steps together, use: $ {parent_command} run APPNAME --instance-id=INSTANCE_ID EXAMPLESz To run the backend gRPC service for the 'finance' sample app using instance 'my-instance', run: $ {command} finance --instance-id=my-instance cURSSS9 URSS[SS9 URS[S S 9 URS S [R"5S S9 URS[SS 9 g)zArgs is called by calliope to gather arguments for this command. Args: parser: An argparse parser that you can use to add arguments that go on the command line after this command. Positional arguments are allowed. rz$The sample app name, e.g. "finance".)help --instance-idTz1The Cloud Spanner instance ID for the sample app.)requiredtyper9 --database-idz1The Cloud Spanner database ID for the sample app.)r<r9z --duration1hza URA5 g [6RBa, URA5 S R1UR<S 9s$f=f) zThis is what gets called when the user runs this 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. APPNAMENr:) projectsId instancesIdz$spanner.projects.instances.databases)params collectionr=zKDatabase {} doesn't exist. Did you run `gcloud spanner samples init` first?zBackend gRPC service killedz0Backend gRPC service timed out after {duration}s)duration)"rr check_appnamercalliope_exceptionsBadArgumentExceptionr VALUEScorer% GetOrFailr& samples_initcheck_instancer'r!r REGISTRYParserGetapitools_exceptionsHttpNotFoundErrorSpannerSamplesErrorrr3r(r RaisesKeyboardInterruptwaitrMKeyboardInterrupt terminateTIMEOUT_EXPIRED_ERR) selfargsrexr%r&r' database_refprocs rRun Backend.RunsllGD G$$$,,668G""KJ!!+. #$$k--g6k%%++!& : ,;L0mmL! w6F6Fyy "D "  2 2 4 $--  5 Y D  4 4Y CCD J  4 4_b IIJ  0 00   %!66KK)) !6+.0 0 0 5 4  + nn *  . ." nn ? F F==G"""s~D>#E' FHG55H> E$EE$' F 1FF G2$A G--G25 H?HHI!"r{si+&' >4/(E6/*)8*N(!" 6