我使用sqlalchemy查询 Impala ，它内部使用 Impala 。

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()

现在，我想获得查询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或任何其他库获取这个？