我正在运行一个计划多次使用的查询。但是,在运行此查询时,“ my-job1a”每次都必须不同,因此我打算在日期时间之前进行设置。有人知道为此实现日期时间功能吗?
from google.cloud import bigquery
client = bigquery.Client('dataworks-356fa')
query = query
dataset = client.dataset('FirebaseArchive')
table = dataset.table(name='test1')
tbl = dataset.table(name='test12')
job = client.run_async_query('my-job1a', query)
job.destination = tbl
job.write_disposition= 'WRITE_TRUNCATE'
job.begin()
最佳答案
我相信“ my-job1a”是一个常量字符串。并且您想要更改新查询的字符串。
import datetime
# "my-job1a" replace this with "my-job1a" + datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
job = client.run_async_query("my-job1a-" + datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"), query)
这将每秒改变。如果要以毫秒为单位,则更改strftime函数参数。如果您不需要这么大的字符串,则根据您的选择更改strftime参数。