如何从 Python 查询远程 snappydata 服务器

Question

我正在尝试从 Python 查询 snappydata，而 StackOverflow 中的一些答案说 Python 无法连接到远程 spark 集群。谁能帮助我如何连接到 snappydata 集群并让一个简单的查询正常工作？

我正在尝试的代码 -

from pyspark.sql.snappy import SnappySession
snappy = SnappySession.builder.appName("test")  \
                              .master("local[*]") \
                              .config("spark.snappydata.connection", "<remote server>:1527") \
                              .getOrCreate()

我收到 FileNotFoundError: [WinError 2] 系统找不到指定的文件。在运行上面的代码。不幸的是，没有太多关于设置环境的信息。但是，我已将我的环境配置为在本地运行 PySpark，它可以正常工作。

Answer 1

SnappyData 的 Python API 不作为 Python 模块分发，您可以从任何 Spark 集群中使用。但是，您可以使用作为 SnappyData 分发的一部分捆绑的 PySpark。