Python中的Apache Beam SQL错误-ValueError：不支持的类型：任何

问题描述

我根据以下代码编写了一个示例 https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/sql_taxi.py

我收到一条错误消息

在

/usr/local/lib/python3.6/dist-packages/apache_beam/typehints/schemas.py中键入_to_runner_api（type_）（177）第177章 178 -> 179提高ValueError（“不支持的类型：％s”％type_） 180 181

ValueError：不支持的类型：任何

代码的相应部分是

   mean_open_close = (
   csv_lines |beam.Map(
       lambda x: beam.Row(
           element_date=x['Date'],element_open=x['Open'],element_close=x['Close']))
   | SqlTransform(
       """
        SELECT
          element_date,AVERAGE(element_open) AS average_open,AVERAGE(element_close) AS average_close
        FROM PCOLLECTION""")

）

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-beam python