BigQuery默认提供了最终一致性，这意味着你无法保证在加载数据之后立即读取到最新的结果。如果你希望立即看到写入的新数据，你可以通过以下两种方式实现读写一致性：

1.使用查询参数

你可以在查询时使用MaxStaleness参数，并指定一个实际秒数，以获得延迟的保证。例如：

query_job = client.query(query, max_results=1, max_staleness=10) #最长延迟10秒

2.使用snapshot时间戳

你可以使用BigQuery提供的snapshot时间戳，它是一个精确到毫秒的时间戳，它可以让你读取指定时间之后的数据。例如：

query_job = client.query(query, snapshot_time=\) #  是指定的时间

同时，在使用流式插入数据时，如果需要保证读写一致性，可以立即调用table.read_rows()查询最新数据。例如：

table.insert_rows([(''), ('')]) # 插入行
rows = list(table.read_rows()) # 获取最新的行

最后，值得注意的是，这样做会增加BigQuery的读取成本，并可能导致查询超时，因此建议使用查询参数或snapshot时间戳来保证读写一致性。