Passer au contenu principal

bigquery@1.1.2

Functions

execute(operations)Operation

Execute a sequence of operations. Wraps language-common/execute, and prepends initial state for http.

load(dirPath, projectId, datasetId, tableId, loadOptions, callback)Operation

Load files to BigQuery

parseCSV(target, config)Operation

CSV-Parse for CSV conversion to JSON

execute(operations) ⇒ Operation

Execute a sequence of operations. Wraps language-common/execute, and prepends initial state for http.

Kind: global function

ParamTypeDescription
operationsOperationsOperations to be performed.

Example

execute(
create('foo'),
delete('bar')
)(state)

load(dirPath, projectId, datasetId, tableId, loadOptions, callback) ⇒ Operation

Load files to BigQuery

Kind: global function
Access: public

ParamTypeDescription
dirPathstringthe path to your local directory
projectIdstringyour bigquery project id
datasetIdstringyour bigquery dataset id
tableIdstringthe name of the table you'd like to load
loadOptionsobjectoptions to pass to the bigquery.load() API
callbackfunctionand optional callback

Example

load(
'./tmp/files',
'my-bg-project',
'test01',
'product-codes',
{
schema: 'FREQ:STRING,DATATYPE:STRING,PRODUCTCODE:STRING,PARTNER:STRING',
writeDisposition: 'WRITE_APPEND',
skipLeadingRows: 1,
schemaUpdateOptions: ['ALLOW_FIELD_ADDITION'],
createDisposition: 'CREATE_IF_NEEDED',
}
)

parseCSV(target, config) ⇒ Operation

CSV-Parse for CSV conversion to JSON

Kind: global function
Access: public

ParamTypeDescription
targetStringstring or local file with CSV data
configObjectcsv-parse config object

Example

parseCSV("/home/user/someData.csv", {
quoteChar: '"',
header: false,
});