const{BigQueryWriteClient}=require('@google-cloud/bigquery-storage');const{status}=require('@grpc/grpc-js');constclient=newBigQueryWriteClient();/** * Gets information about a single write stream. * * @param {string} projectId The project ID of the table. e.g. 'my-project' * @param {string} datasetId The dataset ID of the table. e.g. 'my_dataset' * @param {string} tableId The ID of the table. e.g. 'my_table' */asyncfunctiongetWriteStream(projectId,datasetId,tableId){conststreamId="_default";constname=client.writeStreamPath(projectId,datasetId,tableId,streamId);constrequest={name,};try{const[response]=awaitclient.getWriteStream(request);console.log(`Got write stream:${response.name}`);console.log(`Stream type:${response.type}`);console.log(`Stream location:${response.location}`);}catch(err){if(err.code===status.NOT_FOUND){console.log(`Write stream${name} not found.`);}else{console.error('Error getting write stream:',err);}}}

importgoogle.api_core.exceptionsfromgoogle.cloudimportbigquery_storage_v1defget_write_stream(project_id:str,dataset_id:str,table_id:str,stream_id:str)->None:"""Gets information about a single write stream.    Args:        project_id: The project id.        dataset_id: The dataset id        table_id: The table id        stream_id: The stream id    """client=bigquery_storage_v1.BigQueryWriteClient()stream_name=(f"projects/{project_id}/datasets/{dataset_id}"f"/tables/{table_id}/streams/{stream_id}")try:stream=client.get_write_stream(name=stream_name)print(f"Got write stream:{stream.name}")print(f"Stream type:{stream.Type(stream.type_).name}")exceptgoogle.api_core.exceptions.NotFound:print(f"Write stream not found:{stream_name}")