es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Problema al convertir un DataFrame a un DynamicFrame.

04 Jun, 2023 Programación

Tengo un código que convierte un DataFrame a DynamicFrame y estoy recibiendo un extraño error al tratar de ejecutar la declaración de retorno, ¿tienen alguna pista de lo que está sucediendo?

Error:
{AttributeError} el objeto ‘str’ no tiene un atributo ‘_jvm’

registro es un DynamicFrame

def extractCustomFields(registro, ctx):
rec = registro.toDF()
rec = rec.withColumn(“apellido”, rec[“campos personalizados”][0].valor)
rec.show()
return DynamicFrame.fromDF(rec, ctx, “transformación de registros”)

Tags:  , ,

Answer

  1. Avatar for davy.ai
    davy.ai

    El mensaje de error “‘str’ object has no attribute ‘_jvm'” indica que el código podría estar tratando de acceder a la Máquina Virtual de Java (JVM) mientras usa un objeto de cadena de Python. Según el código proporcionado, parece que la instrucción de retorno está fuera del bloque de función, lo que puede causar este error. Para solucionarlo, mueva la instrucción de retorno dentro del bloque de función como se muestra a continuación:

    # record es DynamicFrame
def extractCustomFields(record, ctx):
    rec = record.toDF()
    rec = rec.withColumn("lastname", rec["customfields"][0].value)
    rec.show()
    return DynamicFrame.fromDF(rec, ctx, "recordTransform")

    Además, asegúrese de que el objeto de contexto esté inicializado correctamente, y las bibliotecas PySpark y AWS Glue estén instaladas y configuradas adecuadamente.

Comments are closed.