Function insertMessageBigquery

packages/bigquery/src/client.ts:164–196

({
  row,
  dataset,
  logger,
}: {
  row: MessageRow
  dataset?: string
  logger: Logger
})

}

export async function insertMessageBigquery({
  row,
  dataset,
  logger,
}: {
  row: MessageRow
  dataset?: string
  logger: Logger
}) {
  const resolvedDataset = dataset ?? DATASET
  try {
    await getClient()
      .dataset(resolvedDataset)
      .table(MESSAGE_TABLE)
      .insert({ ...row, request: JSON.stringify(row.request) })

    logger.debug(
      {
        ...row,
        request: undefined,
      },
      'Inserted message into BigQuery',
    )
    return true
  } catch (error) {
    logger.error(
      { error: getErrorObject(error), messageId: row.id },
      'Failed to insert message into BigQuery',
    )

    return false
  }
}

export async function insertTrace({
  trace,