使用 HiveMetastoreHook 的 get_table(..) 函数来获取精确的列名，如下所示

# imports

from airflow.hooks.hive_hooks import HiveMetastoreHook
from hmsclient.genthrift.hive_metastore import ttypes
from typing import List

# create hook

hive_metastore_hook: HiveMetastoreHook = HiveMetastoreHook(metastore_conn_id="my-hive-metastore-conn-id")

# fetch table object

table: ttypes.Table = mt_hook.get_table(table_name="my_table_name", db="my_db_name")

# determine column names

column_names: List[str] = [field_schema.name for field_schema in table.sd.cols]

..
在此之后，您必须子类 Hiveserver2Hook 修改 to_csv(..) 方法。特别是改变 header 对客户的价值 column_names 上面提取的就足够了。
或者，如果您不希望子类 Hiveserver2Hook ，你可以实现它的 to_csv(..) 分开（例如在 hive_utils.py 文件）并实现相同的行为

我遇到了同样的问题，下面是我发现的一个更简单的方法。
将下面的配置单元配置文件参数传递给 to_csv(..) 方法

hive_conf={"hive.resultset.use.unique.column.names": "false"}

这将抑制列名之前的表名。