Connector for Cloud Spanner

  # This workflow demonstrates how to use the Spanner connector: 
 # Write entries to an existing Spanner database 
 # Your database should have the same schema described in the 
 # `create_transaction` step 
 # Expected output: "SUCCESS" 
 - 
  
 create_table_entry 
 : 
  
 assign 
 : 
  
 - 
  
 project_id 
 : 
  
 ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")} 
  
 - 
  
 spanner_inst 
 : 
  
 "SPANNER_INSTANCE" 
  
 # replace SPANNER_INSTANCE placeholder 
  
 - 
  
 spanner_db 
 : 
  
 "SPANNER_DATABASE" 
  
 # replace SPANNER_DATABASE placeholder 
  
 - 
  
 entry 
 : 
  
 [ 
 "123" 
 ] 
 - 
  
 create_transaction 
 : 
  
 assign 
 : 
  
 - 
  
 req 
 : 
  
 mutations 
 : 
  
 - 
  
 insert 
 : 
  
 columns 
 : 
  
 - 
  
 ID 
  
 table 
 : 
  
 Contacts 
  
 values 
 : 
  
 - 
  
 ${entry} 
  
 singleUseTransaction 
 : 
  
 readWrite 
 : 
  
 {} 
 - 
  
 create_spanner_session 
 : 
  
 call 
 : 
  
 googleapis.spanner.v1.projects.instances.databases.sessions.create 
  
 args 
 : 
  
 database 
 : 
  
 ${"projects/" + project_id + "/instances/" + spanner_inst + "/databases/" + spanner_db} 
  
 result 
 : 
  
 session 
 - 
  
 write_entry 
 : 
  
 call 
 : 
  
 googleapis.spanner.v1.projects.instances.databases.sessions.commit 
  
 args 
 : 
  
 session 
 : 
  
 ${session.name} 
  
 body 
 : 
  
 ${req} 
 - 
  
 delete_spanner_session 
 : 
  
 call 
 : 
  
 googleapis.spanner.v1.projects.instances.databases.sessions.delete 
  
 args 
 : 
  
 name 
 : 
  
 ${session.name} 
 - 
  
 the_end 
 : 
  
 return 
 : 
  
 SUCCESS