Реализация Pyspark:
В этом примере перед сохранением измените поле column_as_array
на column_as_string
.
from pyspark.sql.functions import udf
from pyspark.sql.types import StringType
def array_to_string(my_list):
return '[' + ','.join([str(elem) for elem in my_list]) + ']'
array_to_string_udf = udf(array_to_string,StringType())
df = df.withColumn('column_as_str',array_to_string_udf(d["column_as_array"]))
Затем вы можете удалить старый столбец (тип массива ) перед сохранением.
df.drop("column_as_array").write.csv(...)
Я люблю страпи, это потрясающий инструмент. По моему мнению, если в lambda можно установить laravel, может работать strapi. https://medium.com/artisanhost/hosting-a-laravel-application-on-aws-lamdba-90b7133c8578
Ядром страпи является коа https://github.com/matthewmueller/lambda-serve По моему мнению, вы можете запускать страпи в AWS Lambda.