Мобильная версияПреобразование кадра потоковых данных в формат 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 (последний вызов — последний):
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Как я могу обрабатывать события для получения потоковых данных и файловых данных в WebSockets?
Anonymous » » в форуме C# - 0 Ответы
- 14 Просмотры
-
Последнее сообщение Anonymous
-
