Thanks for stopping by to ask us a question! Please make sure to include:
I'm trying to write to BQ Table via storage API . I have used WriterClient to createSteamConnection and I append rows once the stream is created.
- What code you've already tried
const connection = await this.client.write.createStreamConnection({
streamType,
destinationTable
});
let instance = this;
connection.onConnectionError((err)=>{
console.log('err has happened',err)
instance.init(req);
})
const streamId = connection.getStreamId();
const writer = new Writer({
streamId,
connection,
protoDescriptor
});
then later on
writer.appendRows({ serializedRows: rows });
`
- Any error messages you're getting
code: 10,
details: 'Closing the stream because it has been inactive for 600 seconds.
PLEASE READ: If you have a support contract with Google, please create an issue in the support console instead of filing on GitHub. This will ensure a timely response.
Thanks for stopping by to ask us a question! Please make sure to include:
`
code: 10,
details: 'Closing the stream because it has been inactive for 600 seconds.
PLEASE READ: If you have a support contract with Google, please create an issue in the support console instead of filing on GitHub. This will ensure a timely response.