NameError：名稱'redis'未定義 - PySpark - Redis

Question

我在pyspark中使用addPyFile方法加載redis.zip文件。 我能夠加載使用

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

文件，但同時使用./pyspark運行的代碼，它顯示錯誤：

NameError: name 'redis' is not defined

拉鍊（redis.zip）包含.py文件（client.py，connection.py， exceptions.py,lock.py,utils.py等）。

Python版本是 - 3.5和火花是2.7

Answer 1

如果你收拾PY文件到壓縮和使用sc.addPyFile你應該使用import client，import connector等