首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >如何使用EMR在火花作业中传递参数(EntryPointArguments)?

如何使用EMR在火花作业中传递参数(EntryPointArguments)?
EN

Stack Overflow用户
提问于 2022-11-24 14:23:31
回答 1查看 19关注 0票数 0

**我试图通过参数boto3 (emr-无服务器客户端) EntryPointArguments来传递一些参数来运行我的pyspark脚本,然而,它根本不起作用,我想知道我是否以正确的方式运行它。**

代码语言:javascript
复制
**my python code is like this:**
代码语言:javascript
复制
`

import argparse


parser = argparse.ArgumentParser()

parser.add_argument('-env', nargs='?', metavar='Environment', type=str,
                help='String: Environment to run. Options: [dev, prd]',
                choices=['dev', 'prd'],
                required=True,
                default="prd")

# Capture args
args = parser.parse_args()
env = args.env

print(f"HELLO WOLRD FROM {env}")`
代码语言:javascript
复制
**and my script that runs emr-serverless looks like this:**
代码语言:javascript
复制
jobDriver={
        "sparkSubmit": {
            "entryPoint": "s3://example-bucket-us-east-1-codes-prd/hello_world.py",
            "entryPointArguments": ["-env prd"],
            "sparkSubmitParameters": 
                "--conf spark.executor.cores=2 \
                 --conf spark.executor.memory=4g \
                 --conf spark.driver.cores=2 \
                 --conf spark.driver.memory=8g \
                 --conf spark.executor.instances=1 \
                 --conf spark.dynamicAllocation.maxExecutors=12 \
                ",
        }
代码语言:javascript
复制
**I've already tried putting single quotes, double quotes, I've tried to pass along these parameters in the "sparkSubmitParameters" and so far, nothing works, there aren't many examples of how to do this on the internet, so my hope is that someone has already done it, and achieved, thank you!**
EN

回答 1

Stack Overflow用户

发布于 2022-11-24 14:52:51

--我正在测试它,最后我想出了如何做到这一点。据我所知,当它是这样的对词时:

代码语言:javascript
复制
-env prd

你必须像这样传递EntryPointArguments:

代码语言:javascript
复制
["-env", "prd"]

分离arg,然后传递值,每个值分别传递。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/74562238

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档