Wie eine lokale Avro hochladen große Anfrage an Google mit NodeJS

Question

Ich versuche, eine lokale Avro laden große Abfrage mit NodeJS

var gcloud = require('gcloud')({ 
    keyFilename: './config/keyfile.json', 
    projectId: 'my-project' 
}); 

var bigquery = gcloud.bigquery(); 


var schoolsDataset = bigquery.dataset('my_dataset'); 
var schoolsTable = schoolsDataset.table('person_data'); 


schoolsTable.import('./examples/yob1900.avro', function(err, job) { 
console.log(job) 
console.log(err) 
}); 

Ich erhalte die followin Fehler Google:

{ [ApiError: No schema specified on job or table.] 
    code: 400, 
    errors: 
    [ { domain: 'global', 
     reason: 'invalid', 
     message: 'No schema specified on job or table.' } ], 
    response: undefined, 
    message: 'No schema specified on job or table.' } 

Wie füge ich ein Schema hinzu? (die Datei 'yob1900' wurde von BigQuery Dokumentation heruntergeladen https://cloud.google.com/bigquery/loading-data#loading_json_files)

Answer 1

hier ist die Antwort:

var gcloud = require('gcloud')({ 
    keyFilename: '../config/keyfile.json', 
    projectId: 'my-project' 
}); 

var request = require('request'); 

var bigquery = gcloud.bigquery(); 


var dataset = bigquery.dataset('my_dataset'); 
var table = dataset.table('my_table'); 

var metadata = { 
    sourceFormat: 'AVRO' 
}; 

fs = require('fs'); 

fs.createReadStream('./yob1900.avro') 
    .pipe(table.createWriteStream(metadata)) 
    .on('complete', function(job) { 
    job 
     .on('error', console.log) 
     .on('complete', function(metadata) { 
     console.log('job completed', metadata); 
     }); 
    });