Вы не можете map
использовать фреймворк данных, но вы можете преобразовать dataframe в RDD и сопоставить это, выполнив spark_df.rdd.map()
. До Spark 2.0 spark_df.map
был бы псевдоним spark_df.rdd.map()
. С Spark 2.0 вы должны явно вызвать .rdd
.
Если вы получаете 404, возможно, вы используете версию API, которая не поддерживает отслеживание отгрузки: посмотрите документы, в которых написано Версия 1.5+ поддерживает API REST . Когда вы создаете wcapi
, на какую версию вы указали? Должно выглядеть примерно так (из документов на https://pypi.org/project/WooCommerce/ ):
wcapi = API(
url="http://example.com",
consumer_key="ck_XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
consumer_secret="cs_XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
version="wc/v3"
)