如何通过Python Azure Function读取ClickHouse数据表？

本地环境下运行以下代码可正常读取ClickHouse数据：

import clickhouse_connect
client = clickhouse_connect.get_client(host=host, port=port, username='XXXX', password='XXXX', database = 'MYDB')
df = client.query_df('SELECT TOP (10) * FROM MYTABLE')
print(df)

但部署到Azure Function后，执行df = client.query_df('SELECT TOP (10) * FROM MYTABLE')时触发错误：'NoneType' object has no attribute 'array'。

排查与解决方案 #

• 检查网络连通性
  Azure Function可能无法访问ClickHouse实例：

  • 登录ClickHouse管理控制台，确认防火墙规则已允许Azure Function的出站IP访问（可在Azure门户Function的「概述」页面获取出站IP列表）；
  • 测试环境可临时开启「允许所有Azure服务访问」的规则，验证是否为网络问题。

• 统一依赖包版本
  本地与Azure Function环境的依赖版本不一致可能导致解析异常：

  • 在项目根目录的requirements.txt中明确指定和本地一致的包版本，例如：

    clickhouse_connect==0.6.20
    pandas==2.1.4
    

  • 重新部署Function，确保环境安装的是指定版本的依赖。

• 验证环境变量配置
  确认Azure Function中的连接参数是否正确：

  • 在Azure门户Function的「配置」→「应用程序设置」中，核对host、port、username、password等参数，确保与本地测试时一致；
  • 避免硬编码敏感信息，全部通过应用程序设置注入。

• 调试原始查询结果
  修改代码打印原始查询结果，定位问题环节：

  import clickhouse_connect
  client = clickhouse_connect.get_client(host=host, port=port, username='XXXX', password='XXXX', database = 'MYDB')
  # 先获取原始查询结果
  result = client.query('SELECT TOP (10) * FROM MYTABLE')
  print(f"Query result status: {result.success}")
  print(f"Result columns: {result.columns}")
  print(f"Result row count: {len(result.rows)}")
  # 再转换为DataFrame
  df = result.to_df()
  print(df)
  

  如果result为None或result.rows为空，说明查询未正常返回数据，需优先排查连接或权限问题。

• 排查数据类型兼容性
  某些复杂Nullable数据类型可能在Azure Function环境中解析失败：

  • 先尝试查询简单字段（如SELECT TOP (10) id, name FROM MYTABLE），验证是否能正常转换为DataFrame；
  • 逐步添加字段，定位到触发错误的特定数据类型，再针对性处理（比如用ClickHouse函数转换类型）。

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