function insertHandler(insertErrors, apiResponse) {
apiResponseを受け取り、insertErrorsを受け取らない場合、インポートが完了したか、インポートが開始されている(現在インポート中)ことを意味しますか?BigQueryデータストリーム操作が完了しているかどうかを確認する方法
インポートされたデータに対してクエリを実行しようとしていますが、インポートが正常に終了したことを知る必要があります。
function insertHandler(insertErrors, apiResponse) {
apiResponseを受け取り、insertErrorsを受け取らない場合、インポートが完了したか、インポートが開始されている(現在インポート中)ことを意味しますか?BigQueryデータストリーム操作が完了しているかどうかを確認する方法
インポートされたデータに対してクエリを実行しようとしていますが、インポートが正常に終了したことを知る必要があります。
データをストリーミングすると、最初にいわゆる "ストリーミングバッファ"に入ります。
ストリーミングバッファは実際にはbigtableです。ストリーミングバッファ内のデータは、bigqueryテーブルにすでにあるデータとともに安全に照会することができます。bigqueryエンジンは、bqテーブルだけでなく、それぞれのbigtableをフェデレーテッドソースとしてクエリするためです。
つまり、jobs.insertおよびjobs.query API(およびそれぞれのクライアント固有の実装)が完璧に機能します。
同時に、tabledata.list API(およびそれぞれのクライアントメソッド)はストリーミングバッファにあるデータを返しません。