2016-08-07 36 views
1

Ich benutze const google = require('googleapis'); in google bigquery streamen, aber jetzt, wenn ich meine Datenbank auswählen möchte, bin ich verwirrt. Ein Blick in die Dokumentation, die ich verwenden muss bigquery.jobs.query, aber ich verstehe nicht, wo die tatsächliche Auswahl platziert werden sollte.Wie wähle ich mit googleapis bigquery api

var query = `select 1 `; 
bqBooking.auth = jwtClient; 
bigquery.jobs.query(bqBooking, function (err, rows) { 
    if (err) { 
     return callback(err); 
    } 

    printExample(rows); 
    callback(null, rows); 
}); 

Antwort

0
/** 
* Run an example query. 
* 
* @param {Function} callback Callback function. 
*/ 
function queryExample (callback) { 
    var query = 'SELECT TOP(corpus, 10) as title, COUNT(*) as unique_words\n' + 
    'FROM [publicdata:samples.shakespeare];'; 

    bigquery.query(query, function (err, rows) { 
    if (err) { 
     return callback(err); 
    } 

    printExample(rows); 
    callback(null, rows); 
    }); 
} 

https://cloud.google.com/bigquery/create-simple-app-api

+0

Das Problem ist, dass dieses Beispiel verwendet var gcloud = require ('gcloud'); während ich const verwende google = require ('googleapis'); –

0

Kann Abfrage als Parameter in 'Antrag Body' von bigQuery.jobs.query example passieren, wie in link gezeigt Bitte verwenden 'Versuchen Sie, diese API' Option im zweiten Link.

var google = require('googleapis'); 
var bigquery = google.bigquery('v2'); 

authorize(function(authClient) { 
var request = { 
// Project ID of the project billed for the query 
    projectId: '', // TODO: Update placeholder value. 

    resource: { 
     // TODO: Add desired properties to the request body. 
     "query": "Select channel, sum(totalRequests) from 
     conversation_logs.RequestSummary WHERE timeStamp > 
     TIMESTAMP('2017-09-03 00:00:00 UTC') Group by channel;", 
     "maxResults": 1, 
     "useLegacySql": false 
    }, 

    auth: authClient 
}; 

bigquery.jobs.query(request, function(err, response) { 
    if (err) { 
     console.log(err); 
     return; 
    } 

    // TODO: Change code below to process the `response` object: 
    console.log(JSON.stringify(response, null, 2)); 
}); 
}); 

function authorize(callback) { 
    google.auth.getApplicationDefault(function(err, authClient)) { 
    if (err) { 
     console.log('authentication failed: ', err); 
     return; 
    } 
    if (authClient.createScopedRequired && 
     authClient.createScopedRequired()) { 
     var scopes = ['https://www.googleapis.com/auth/cloud- 
     platform']; 
     authClient = authClient.createScoped(scopes); 
     } 
     callback(authClient); 
    }); 
}