我正在执行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。地图应用程序。为我工作。