为什么气流在请求 Rest API 时返回错误?

Why airflow is returning error while requesting Rest API?

我有一个 python 代码请求休息 API。 API 有 5000 多页,所以我试图请求它,但我总是在第 2000 次请求时出错。

错误是:“df = pd.json_normalize(json_data["items"]) 键错误:'items'” 我怎么解决这个问题 ? P.S。在本地,代码运行清晰。

我找到了解决这个问题的方法。正如@elad 所说,这不是气流错误。由于气流网络服务和调度程序,系统运行速度稍慢。所以,我的令牌在气流任务 运行 时过期了。我重新组织了我的代码,我在循环中生成了具有特定条件的令牌,例如 try-except。感谢一切!