小编cal*_*lor的帖子

如何停止/退出 AWS Glue 作业 (PySpark)?

我成功运行了一个 AWS Glue 作业,用于转换数据以进行预测。如果达到特定条件,我想停止处理并输出状态消息(正在运行):

if specific_condition is None:
    s3.put_object(Body=json_str, Bucket=output_bucket, Key=json_path )
    return None
Run Code Online (Sandbox Code Playgroud)

这会产生“SyntaxError:'return'外部函数”,我尝试过:

if specific_condition is None:
    s3.put_object(Body=json_str, Bucket=output_bucket, Key=json_path )
    job.commit()
Run Code Online (Sandbox Code Playgroud)

这不是在 AWS Lambda 中运行,而是使用 Lambda 启动的胶水作业(例如 start_job_run())。

amazon-web-services aws-glue aws-glue-spark

6
推荐指数
1
解决办法
6553
查看次数