如何获取通过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 (将#修改为@）

cloudera-manager impala python sqlalchemy