在AWS EMR上的MapReduce代码中导入自定义函数(import custom function in MapReduce code on AWS EMR)

 我一直在努力奋斗2个小时吧！ 
 
 我在python中创建了一个mapper脚本，它在其他python脚本中导入我的一个自定义函数。 
 
    #!/usr/bin/env python
    import sys

    import testImport

    for line in sys.stdin:
        if line and line!='':
            words = line.strip().lower().split('\t')
            print '%s\t%s' % (words[0].strip(),testImport.age_classify(int(words[1])))
 
 这段代码在我的终端上运行良好....问题是我将这个映射器函数上传到AWS Elastic MapReduce。 我的工作失败，错误地说“导入模块testImport失败”。 
 
 testImport是一个文件'testImport.py'，它包含我的一些辅助函数（比如age_classify函数），我需要在每行标准输入上操作。 
 
 我将脚本与我的映射器脚本（给定脚本）放在同一个桶中。 
 
 当我添加'Streaming program'步骤时，我试图在参数部分传递它。 即使看到所有相关问题，我也不知道该怎么办。 
 
 我怎么能这样做??? 
 
 任何帮助都会非常棒！ 
 
 谢谢！ 

I have been struggling with this for 2 hours now!
 
I created a mapper script in python which is importing one of my custom functions in other python script.
 
    #!/usr/bin/env python
    import sys

    import testImport

    for line in sys.stdin:
        if line and line!='':
            words = line.strip().lower().split('\t')
            print '%s\t%s' % (words[0].strip(),testImport.age_classify(int(words[1])))
 
This code works well on my terminal....the problem is when i upload this mapper function to AWS Elastic MapReduce. My job fails with error saying "Failed to import module testImport".
 
testImport is a file 'testImport.py' which contains some of my helper functions (like the age_classify function), which i need to operate on each line of standard input.
 
I uploaded the script in the same bucket as my mapper script(the given script).
 
I tried to pass it in the arguments section when i add 'Streaming program' step. I have no clue what to do even after seeing all the related questions.
 
How can i get this done???
 
Any help would be really great!
 
Thank you!

原文：https://stackoverflow.com/questions/26824319