BigTable createReadStream error handling

Hi, I am using BigTable createReadStream and it seems to be hanging on errors from BigTable.
I am using through2.obj as recommended in #1715:

Perhaps I'm using the API incorrectly? I couldn't find any examples of this in the documentation.

    eventsTable
      .createReadStream({
        decode: true,
        start: rowKey,
        end: `${appID}|${recordingID}||`,
        filter: [{
          family: 'metadata',
          column: {
            cellLimit: 1,
          },
        }],
      })
      .pipe(through2.obj(async (row, _, next) => {
          await doWork();
      }))
      .on('data', () => {
        // For some reason we need to have a data block in order for 'end' to be called.
      })
      .on('error', reject)
      .on('end', async () => {
        resolve();
      });

@arbesfeld

@arbesfeld I'm going to update the example in that issue, but the stream emits a finish event not end in this particular instance.

eventsTable
  .createReadStream({
    decode: true,
    start: rowKey,
    end: `${appID}|${recordingID}||`,
    filter: [{
      family: 'metadata',
      column: {
        cellLimit: 1,
      },
    }],
  })
  .pipe(through2.obj(async (row, _, next) => {
      await doWork();
      next();
  }))
  .on('error', reject)
  .on('finish', async () => {
    resolve();
  });

chore: clean up release-brancher config stuff from #1755, manually ad…

fix: Update GAX (#1758)

fix: add sleep after admin request intensive tests (#1758)

chore(main): release 6.6.0 (#1752)

chore: clean up release-brancher config stuff from #1755, manually ad…

Navigation Menu

Repository navigation

BigTable createReadStream error handling #1758

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

BigTable createReadStream error handling #1758

Description

Activity

callmehiphop commented on Oct 31, 2016

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions