Sur le flux de travail GUI Treasure,
+run_query:
td_run>: sample_query
Vous pouvez exécuter la requête avec le nom de la requête sur Treasure Data. Cependant, il semble qu'il n'y ait pas de telle fonction du côté du client Python. (Pourrait arriver)
** Utilisez run_schedule **
import time
import tdclient
if __name__ == '__main__':
query_name = 'sample_query'
with tdclient.Client(apikey='hogehoge') as td:
# get unix time
unix_time = int(time.time())
run_time = unix_time + 10
# set schedule query
# run now!
res = td.run_schedule(name=query_name, time=run_time, num=1)
return 0
import time
import tdclient
def main():
query_name = 'sample_query'
with tdclient.Client(apikey='hogehoge') as td:
unix_time = int(time.time())
run_time = unix_time + 10
# set schedule query
# run now!
res = td.run_schedule(name=query_name, time=run_time, num=1)
schedule_job = res[0]
# get job_id from ScheduleJob object
job_id = schedule_job._job_id
# get Job object by job_id
job = td.job(job_id=job_id)
# wait until job finished
job.wait()
# get results one by one
for row in job.result():
print(repr(row))
return 0
if __name__ == '__main__':
main()
La raison pour laquelle je voulais répondre à la requête sur Treasure Data est ... Je voulais utiliser celui avec Connector sur l'interface graphique de Treasure Data. Bien sûr, je pourrais définir Export sur Python, mais je voulais le porter de côté.
Client officiel Python GitHub - Treasure Data API library for Python
Recommended Posts