Запись пользовательских фреймов данных из pyspark в Azure Event Hub - PullRequest
0 голосов
/ 25 сентября 2019

Попытка добавить пользовательский фрейм данных Pandas в Azure Event Hub.Вот код:

  dic = { 
           'body' : filter_data
    }
    df = pd.DataFrame(dic,index=[0])
    df1 = df.astype(str)
    ds = df1 \
        .select('body') \
  .write \
  .format("eventhubs") \
  .options(**ehEventConf) \
  .option("checkpointLocation", "output") \
  .save()

Я получаю сообщение об ошибке типа "TypeError: 'str' object is not callable"

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...