Преобразование кадра потоковых данных в формат JSON в Python ⇐ Python
-
Anonymous
Преобразование кадра потоковых данных в формат JSON в Python
из функций импорта pyspark.sql как F импортировать бото3 импортировать систему ## установить транслируемые переменные table_name = "dev.emp.master_events" df = ( spark.readStream.format("дельта") .option("readChangeFeed", "истина") .option("начальная версия", 2) .table(имя_таблицы) ) элементы = df.select('*') запрос = (items.writeStream.outputMode("append").foreachBatch(лямбда-элементы, epoch_id: items.write.json()).start()) Ошибка перехода ниже
py4j.Py4JException: прокси-сервер Python вызвал исключение. Возвратное сообщение: Traceback (последний вызов — последний):
из функций импорта pyspark.sql как F импортировать бото3 импортировать систему ## установить транслируемые переменные table_name = "dev.emp.master_events" df = ( spark.readStream.format("дельта") .option("readChangeFeed", "истина") .option("начальная версия", 2) .table(имя_таблицы) ) элементы = df.select('*') запрос = (items.writeStream.outputMode("append").foreachBatch(лямбда-элементы, epoch_id: items.write.json()).start()) Ошибка перехода ниже
py4j.Py4JException: прокси-сервер Python вызвал исключение. Возвратное сообщение: Traceback (последний вызов — последний):
