Невозможно импортировать модуль pyspark.pipelines. ⇐ Python

[Anonymous]

Что может быть причиной следующей ошибки моего кода в блокноте Databricks и как мы можем исправить эту ошибку?

Ошибка импорта: невозможно импортировать имя «конвейеры» из «pyspark» (/databricks/python/lib/python3.12/site-packages/pyspark/init.py)

Это верхняя строка записной книжки Databricks, в которой выдается ошибка:

Код: Выделить всё

from pyspark import pipelines as dp

Согласно следующей цитате из «Основы Python для разработки конвейеров» от команды Databricks, нам необходимо импортировать вышеуказанный модуль для создания декларативных конвейеров Lakeflow с использованием Python:

Все API-интерфейсы Python декларативных конвейеров Lakeflow реализованы в модуле pyspark.pipelines.

Кроме того, как мы знаем, PySpark — это неотъемлемый и основной программный интерфейс, используемый на платформе Databricks. Итак, что же мне здесь не хватает, что вызывает ошибку?

Подробнее здесь: https://stackoverflow.com/questions/797 ... nes-module