Traceback fromDF (последний вызов был последним): - PullRequest
Новая
       7

Traceback fromDF (последний вызов был последним):

0 голосов
/ 06 января 2020

У меня проблемы с передачей фрейма данных в динамический c фрейм, потому что записная книжка или следующая ошибка:

Traceback (последний вызов был последним): Файл "/ mnt / yarn / usercache / livy / appcache / application_1578332582273_0001 / container_1578332582273_0001_01_000001 / pyspark.zip / pyspark / sql / types.py ", строка 1532, в getattr повышение атрибутаError (элемент) 100 * * ошибка * элемент 7 * код с ошибкой 

for types in eventTypes:
    for row in data:
        if(row.event_type == types):
            dyf = row.fromDF(dataframe = row, glue_ctx = glueContext, name = "DynamicFrame")
            row.fromDF()

            glueContext.write_dynamic_frame.from_options(frame = teste, connection_type = "s3", connection_options = {"path": "s3://houpa-event-types/{}".format(types), "compression": "gzip"}, format = "json", transformation_ctx = "datasink2")

        else:
            print('erro')

Кто-нибудь может мне помочь?

...