如何解决如何获取通过sqlalchemy执行的Impala查询的查询ID
我正在使用内部使用sqlalchemy的impyla查询黑斑羚。
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
engine = create_engine("impala://{host}:{port}/{database}".format(
host=host,port=21051,database=schema
))
Session = sessionmaker(bind=engine,autocommit=False)
_session = Session()
result = _session.execute("""SELECT * FROM TABLE1 LIMIT 2""")
data = result.fetchall()
print(data)
_session.close()
Session.close_all()
现在,我要获取的query_id可以用来在Cloudera Manager UI中监视此查询的进度。
例如,如果我在控制台中使用imapal-shell执行相同的查询。
我明白了:
[MYMACHINE:21001] > select * from table1 limit 2;
Query: select * from table1 limit 2
Query submitted at: 2020-08-24 10:28:15 (Coordinator: http://MYMACHINE:25000)
Query progress can be monitored at: http://MYMACHINE:25000/query_plan?query_id=8646e69bf8aa9707:df03d6ff00000000
我需要记录此查询ID 8646e69bf8aa9707:df03d6ff00000000 。
我可以使用sqlalchemy或其他任何库来获取此信息吗?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。