<p><a href="https://github.com/rounds/go-bqstreamer" rel="nofollow">https://github.com/rounds/go-bqstreamer</a></p>
<p>Where in this project does it read from the queue? Is it a database, or a redis queue, or what? Never mind where it's writing to (BigQuery).</p>
<hr/>**评论:**<br/><br/>Fwippy: <pre><p>Not 100% sure what you're asking.</p>
<p>It looks like you need to queue the rows yourself: <a href="https://godoc.org/github.com/rounds/go-bqstreamer#Streamer.QueueRow" rel="nofollow">https://godoc.org/github.com/rounds/go-bqstreamer#Streamer.QueueRow</a></p>
<p>Internally, those are read here: <a href="https://github.com/rounds/go-bqstreamer/blob/master/streamer.go#L129" rel="nofollow">https://github.com/rounds/go-bqstreamer/blob/master/streamer.go#L129</a> , where they then decide whether the batch of stored rows should be sent to BigQuery. </p></pre>DEATH-BY-CIRCLEJERK: <pre><p>This helps. Thanks!</p></pre>
