Python3.9.7通过PySimpleGUI传参连接Hive报gaierror异常

在Python 3.9.7环境下对接Hive时，直接在脚本中硬编码连接参数可成功建立连接，但通过自行编写的PySimpleGUI图形界面传入相同连接参数时，会连续抛出两类报错：

• 域名解析错误：gaierror: [Errno 8] nodename nor servname provided, or not known
• 连接层异常：TTransportException: TTransportException(type=1, message="Could not connect to host,port,auth_mech,kerb_serv_name,timeout,use_ssl")

如果不使用GUI传入的参数拼接连接串，直接在代码里写入固定参数值，程序可正常执行。原实现代码如下：

import pandas as pd
import PySimpleGUI as sg
from impala.dbapi import connect
from impala.util import as_pandas

layout_h = [
    [sg.Text('host',size=(10,1)),sg.Input(key='h')],
    [sg.Text('port',size=(10,1)),sg.Input(key='p')],
    [sg.Text('auth_mechanism',size=(10,1)),sg.Input(key='am')],
    [sg.Text('kerberos_service_name',size=(10,1)),sg.Input(key='ksn')],
    [sg.Text('timeout',size=(10,1)),sg.Input(key='t')],
    [sg.Text('use_ssl(True/False)',size=(10,1)),sg.Input(key='ssl')],
    [sg.Button('Test Connection'),sg.Button('Quit')],
    [sg.Text('Enter SQL',size=(10,1)),sg.Input(key='sqlquery1')],
    [sg.Button('Profile and Save'),sg.Button('Exit')]
]
sg.theme('dark grey 6')
window = sg.Window('Hive',layout_h)
event,values = window.read()
if event == 'Test Connection':
    hiv = connect(str(values['h'])+","+values['p']+","+str(values['am'])+","+str(values['ksn'])+","+values['t']+","+values['ssl'])

    imp_cursor = hiv.cursor()
    imp_cursor.execute(values['sqlquery1'])
    AV = as_pandas(imp_cursor)

你的怀疑是对的，核心错误是connect方法的传参方式完全错误：

1. impala.dbapi.connect 不接收逗号拼接的单字符串作为入参，需要为每个连接参数指定对应的关键字参数。你现在把所有参数拼成一整个字符串传入，程序会把这整串内容当做Hive服务的主机名去做DNS解析，自然会触发域名找不到的gaierror。
2. PySimpleGUI的输入框返回值全部为字符串类型，而connect方法要求port、timeout为整数类型，use_ssl为布尔类型，直接传字符串会触发参数类型不匹配的潜在问题。

去掉字符串拼接逻辑，按connect的参数定义逐个传值，同时对GUI返回的字符串做对应类型转换，修复后的连接逻辑代码如下：

if event == 'Test Connection':
    # 读取GUI输入值，先去除首尾误输入的空格
    host = values['h'].strip()
    port = int(values['p'].strip())
    auth_mechanism = values['am'].strip()
    # 未填写kerberos服务名时传None即可
    kerberos_service_name = values['ksn'].strip() if values['ksn'].strip() else None
    timeout = int(values['t'].strip())
    # 字符串转布尔值，不区分大小写输入True/False
    use_ssl = values['ssl'].strip().lower() == 'true'

    hiv = connect(
        host=host,
        port=port,
        auth_mechanism=auth_mechanism,
        kerberos_service_name=kerberos_service_name,
        timeout=timeout,
        use_ssl=use_ssl
    )

    imp_cursor = hiv.cursor()
    imp_cursor.execute(values['sqlquery1'])
    AV = as_pandas(imp_cursor)

额外提示：如果你的连接还需要用户名、密码参数，可以在GUI中新增对应输入框，读取后通过user、password关键字参数传入connect方法即可。

内容的提问来源于stack exchange，提问作者dragnblow