如何将输入参数传递给AWS Glue Map.apply函数



我正在执行AWS Glue作业,其中我有一个函数"some_function",我想将其应用于DynamicFramedy_f,但我也想将输入参数传递给some_function。

Map.apply(frame=products_combination, f=search)

其中some_function的定义是:

some_function(record, k)

到目前为止,我已经尝试过:作品:

Map.apply(frame=products_combination, f=search) ##provided i'm not taking k as input in some_function def as well

出现错误的原因:

Map.apply(frame=products_combination, f=search(k=10))

这返回"0";TypeError:search((缺少1个必需的位置参数:"record">

如何将参数传递给Map.apply函数?我已经浏览了[这里]的文档,但在那里找不到我的解决方案。1

您总是可以通过lambda:传入其他参数

Map.apply(frame=products_combination, f=lambda record: search(record, k=10))

我最终使用了Spark udf而不是DynamicFrame。地图应用程序。为我工作。

最新更新