python - NameError：名称'redis'未定义 - PySpark - Redis

Question

我正在使用addPyFilepyspark 中的方法来加载redis.zip文件。我可以使用加载文件

sc.addPyFile("/home/path/to/redis.zip")

但是在使用 运行代码时./pyspark，它显示错误：

NameError：名称'redis'未定义

zip( redis.zip) 包含.py文件（client.py、connection.py、exceptions.py、lock.py等utils.py）。

Python 版本是 - 3.5，火花是 2.7

Answer 1

如果您将 py 文件打包成 zip 并使用添加它，您应该使用,等sc.addPyFile导入模块。import clientimport connector