我如何实现尝试,除了在我的 python 脚本上,我使用 kubernetes python 客户端与我的 GKE 集群通信。如果它不存在,我想创建一个部署。我目前正在这样做(下面的代码),但它似乎不起作用,因为它返回 API 异常错误并且程序崩溃。
这是我当前的实现
def get_job():
conn.connect()
api = client.CustomObjectsApi()
for message in consumer:
message = message.value
try:
resource = api.get_namespaced_custom_object(
group="machinelearning.seldon.io",
version="v1",
name=message["payload"]["metadata"]["name"],
namespace="seldon",
plural="seldondeployments",
) # execution stops here and doesn't move to the next step.
api.create_namespaced_custom_object(
group="machinelearning.seldon.io",
version="v1",
namespace="seldon",
plural="seldondeployments",
body=message['payload'])
print("Resource created")
print(e)
else:
pass
我怎样才能解决这个问题?我试图遵循的逻辑是这样的
- 如果部署存在,则返回一个已经存在的消息,而不会使脚本崩溃。
- 如果部署不存在,请创建一个新部署。