// The analyticshub quickstart application demonstrates usage of the// Analytics hub API by creating an example data exchange and listing.packagemainimport("context""flag""fmt""log"analyticshub"cloud.google.com/go/bigquery/analyticshub/apiv1""cloud.google.com/go/bigquery/analyticshub/apiv1/analyticshubpb""google.golang.org/grpc/codes""google.golang.org/grpc/status")funcmain(){// Define the command line flags for controlling the behavior of this quickstart.var(projectID=flag.String("project_id","","Cloud Project ID, used for session creation.")location=flag.String("location","US","BigQuery location used for interactions.")exchangeID=flag.String("exchange_id","ExampleDataExchange","identifier of the example data exchange")listingID=flag.String("listing_id","ExampleDataExchange","identifier of the example data exchange")exampleDatasetSource=flag.String("dataset_source","","dataset source in the form projects/myproject/datasets/mydataset")delete=flag.Bool("delete_exchange",true,"delete exchange at the end of quickstart"))flag.Parse()// Perform simple validation of the specified flags.if*projectID==""{log.Fatal("empty --project_id specified, please provide a valid project ID")}if*exampleDatasetSource==""{log.Fatalf("empty --dataset_source specified, please provide in the form \"projects/myproject/datasets/mydataset\"")}// Instantiate the client.ctx:=context.Background()ahubClient,err:=analyticshub.NewClient(ctx)iferr!=nil{log.Fatalf("NewClient: %v",err)}deferahubClient.Close()// Then, create the data exchange (or return information about one already bearing the example name), and// print information about it.exchange,err:=createOrGetDataExchange(ctx,ahubClient,*projectID,*location,*exchangeID)iferr!=nil{log.Fatalf("failed to get information about the exchange: %v",err)}fmt.Printf("\nData Exchange Information\n")fmt.Printf("Exchange Name: %s\n",exchange.GetName())ifdesc:=exchange.GetDescription();desc!=""{fmt.Printf("Exchange Description: %s",desc)}// Finally, create a listing within the data exchange and print information about it.listing,err:=createListing(ctx,ahubClient,*projectID,*location,*exchangeID,*listingID,*exampleDatasetSource)iferr!=nil{log.Fatalf("failed to create the listing within the exchange: %v",err)}fmt.Printf("\n\nListing Information\n")fmt.Printf("Listing Name: %s\n",listing.GetName())ifdesc:=listing.GetDescription();desc!=""{fmt.Printf("Listing Description: %s\n",desc)}fmt.Printf("Listing State: %s\n",listing.GetState().String())ifsource:=listing.GetSource();source!=nil{ifdsSource,ok:=source.(*analyticshubpb.Listing_BigqueryDataset);ok &&dsSource.BigqueryDataset!=nil{ifdataset:=dsSource.BigqueryDataset.GetDataset();dataset!=""{fmt.Printf("Source is a bigquery dataset: %s",dataset)}}}// Optionally, delete the data exchange at the end of the quickstart to clean up the resources used.if*delete{fmt.Printf("\n\n")iferr:=deleteDataExchange(ctx,ahubClient,*projectID,*location,*exchangeID);err!=nil{log.Fatalf("failed to delete exchange: %v",err)}fmt.Printf("Exchange projects/%s/locations/%s/dataExchanges/%s was deleted.\n",*projectID,*location,*exchangeID)}fmt.Printf("\nQuickstart completed.\n")}// createOrGetDataExchange creates an example data exchange, or returns information about the exchange already bearing// the example identifier.funccreateOrGetDataExchange(ctxcontext.Context,client*analyticshub.Client,projectID,location,exchangeIDstring)(*analyticshubpb.DataExchange,error){req:=&analyticshubpb.CreateDataExchangeRequest{Parent:fmt.Sprintf("projects/%s/locations/%s",projectID,location),DataExchangeId:exchangeID,DataExchange:&analyticshubpb.DataExchange{DisplayName:"Example Data Exchange",Description:"Exchange created as part of an API quickstart",PrimaryContact:"",Documentation:"https://link.to.optional.documentation/",},}resp,err:=client.CreateDataExchange(ctx,req)iferr!=nil{// We'll handle one specific error case specially, the case of the exchange already existing.  In this instance,// we'll issue a second request to fetch the exchange information for the already present exchange and return it.ifcode:=status.Code(err);code==codes.AlreadyExists{getReq:=&analyticshubpb.GetDataExchangeRequest{Name:fmt.Sprintf("projects/%s/locations/%s/dataExchanges/%s",projectID,location,exchangeID),}resp,err=client.GetDataExchange(ctx,getReq)iferr!=nil{returnnil,fmt.Errorf("error getting dataExchange: %w",err)}returnresp,nil}// For all other cases, return the error from creation request.returnnil,err}returnresp,nil}// createListing creates an example listing within the specified exchange using the provided source dataset.funccreateListing(ctxcontext.Context,client*analyticshub.Client,projectID,location,exchangeID,listingID,sourceDatasetstring)(*analyticshubpb.Listing,error){req:=&analyticshubpb.CreateListingRequest{Parent:fmt.Sprintf("projects/%s/locations/%s/dataExchanges/%s",projectID,location,exchangeID),ListingId:listingID,Listing:&analyticshubpb.Listing{DisplayName:"Example Exchange Listing",Description:"Example listing created as part of an API quickstart",Categories:[]analyticshubpb.Listing_Category{analyticshubpb.Listing_CATEGORY_OTHERS,},Source:&analyticshubpb.Listing_BigqueryDataset{BigqueryDataset:&analyticshubpb.Listing_BigQueryDatasetSource{Dataset:sourceDataset,},},},}returnclient.CreateListing(ctx,req)}// deleteDataExchange deletes a data exchange.funcdeleteDataExchange(ctxcontext.Context,client*analyticshub.Client,projectID,location,exchangeIDstring)error{req:=&analyticshubpb.DeleteDataExchangeRequest{Name:fmt.Sprintf("projects/%s/locations/%s/dataExchanges/%s",projectID,location,exchangeID),}returnclient.DeleteDataExchange(ctx,req)}

/** * TODO(developer): Uncomment these variables before running the sample. *//** *  Required. The parent resource path of the DataExchanges. *  e.g. `projects/myproject/locations/US`. */// const parent = 'abc123'/** *  The maximum number of results to return in a single response page. Leverage *  the page tokens to iterate through the entire collection. */// const pageSize = 1234/** *  Page token, returned by a previous call, to request the next page of *  results. */// const pageToken = 'abc123'// Imports the Dataexchange libraryconst{AnalyticsHubServiceClient}=require('@google-cloud/bigquery-data-exchange').v1beta1;// Instantiates a clientconstdataexchangeClient=newAnalyticsHubServiceClient();asyncfunctioncallListDataExchanges(){// Construct requestconstrequest={parent,};// Run requestconstiterable=awaitdataexchangeClient.listDataExchangesAsync(request);forawait(constresponseofiterable){console.log(response);}}callListDataExchanges();