Problema al convertir un DataFrame a un DynamicFrame.
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”)
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:
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.