我有以下工作python代码来执行impala连接/查询:
import pandas as pd
query = 'select my_c_instance_id, count(my_c_instance_id) as my_ins_id_count from ' + \
'(select * from my_table where my_c_id like "%small%") as small_table' + \
' group by(my_c_instance_id)'
cursor = impala_con.cursor()
cursor.execute('USE my_db')
cursor.execute(query)
df_result = as_pandas(cursor)
df_result
代码运行良好,但我想知道是否有可能将其分成两个更可读的部分,例如:
small_table = 'select * from my_table where my_c_id like "%small%"'
query = 'select my_c_instance_id, count(my_c_instance_id) as my_ins_id_count from small_table group by(my_c_instance_id)'
cursor = impala_con.cursor()
cursor.execute('USE my_db')
cursor.execute(query)
df_result = as_pandas(cursor)
df_result
如果可能的话,我如何让上述想法真正起作用?谢谢。
1条答案
按热度按时间ykejflvf1#
除非我误解了什么,否则根本不需要子查询,只要移动
where
主查询的条件: