NameError: имя «redis» не определено — PySpark — Redis

Я использую метод addPyFile в pyspark для загрузки файла 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.


python redis apache-spark pyspark redis-py
person vegeta    schedule 03.03.2017    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Если вы упаковываете py-файлы в zip и добавляете их с помощью sc.addPyFile, вы должны импортировать модули с помощью import client, import connector и т. д.

person Mariusz    schedule 03.03.2017