在PySpark中通过抛出自定义异常终止Notebook运行

直接通过raise语句抛出异常即可终止Notebook运行，以下是修正后的代码实现：

方案1：使用内置Exception抛出错误 #

response = opener.open(url, data)
resp = response.read().decode('utf-8')
# 替换为你实际要检查的目标字符串
target_str = "需要匹配的内容"
if target_str in resp:
    print("yes continue execution")
else:
    # 抛出异常，触发Notebook终止
    raise Exception("Notebook终止：响应内容中未找到目标字符串")

方案2：自定义异常类（更清晰的错误类型） #

# 定义自定义异常
class TargetContentNotFound(Exception):
    """当响应中未找到目标内容时抛出的异常"""
    pass

response = opener.open(url, data)
resp = response.read().decode('utf-8')
target_str = "需要匹配的内容"
if target_str in resp:
    print("yes continue execution")
else:
    raise TargetContentNotFound("Notebook终止：响应内容中未找到指定字符串")

关键注意点 #

• 原代码中使用str作为变量名是错误的，str是Python内置类型，必须替换为实际的目标字符串变量（比如上面的target_str），这可能是你之前尝试失败的原因之一。
• 只有通过raise主动抛出异常，Notebook才会终止后续执行并显示错误信息，单纯打印提示不会触发终止。

内容的提问来源于stack exchange，提问作者TalendDeveloper