bq

Documentation

Overview

Package bq implements bigquery-related logic.

Index

• func GetPSTTimeStamp(t time.Time) string
• func InitBQUploader(ctx context.Context, project, dataset, table string) (*bq.Uploader, error)
• func InitBQUploaderWithClient(ctx context.Context, client *bigquery.Client, dataset, table string) *bq.Uploader

Functions

func GetPSTTimeStamp

func GetPSTTimeStamp(t time.Time) string

GetPSTTimeStamp returns the PST timestamp for bq table.

func InitBQUploader

func InitBQUploader(ctx context.Context, project, dataset, table string) (*bq.Uploader, error)

InitBQUploader initialize a bigquery uploader.

func InitBQUploaderWithClient

func InitBQUploaderWithClient(ctx context.Context, client *bigquery.Client, dataset, table string) *bq.Uploader

InitBQUploaderWithClient initialize a bigquery uploader with a given bigquery client.