使用 python 客户端删除 Kubernetes 资源

Question

想使用K8s的python客户端，删除statefulset等部分资源。我可以删除 statefulset 本身，但 Ks8 不会删除运行 pods。我发现了一些示例，他们在删除选项中设置了 propagation_policy="Foreground" 并完成了工作，但问题出在 kubernetes 客户端 > 9.0 他们更改了 API 并且当我通过 delete_options 它时returns 这个错误：

TypeError: delete_namespaced_stateful_set() takes 3 positional arguments but 4 were given

我试图找到设置删除传播策略的正确方法，但它没有用，运行 pods 没有被杀死，我如何删除所有运行 pods 和 statefuleset 在一次 api 调用中？

我当前删除状态集的代码：

api_response = k8s_api.delete_namespaced_stateful_set(statefulset_name,namespace)

产生上述错误的代码：

delete_options = client.V1DeleteOptions(propagation_policy="Foreground", grace_period_seconds=5)
api_response = k8s_api.delete_namespaced_stateful_set(statefulset_name,namespace,delete_options)

Answer 1

看完source code:

def delete_namespaced_stateful_set(self, name, namespace, **kwargs):
    """
    delete a StatefulSet
    This method makes a synchronous HTTP request by default. To make an
    asynchronous HTTP request, please pass async_req=True
    >>> thread = api.delete_namespaced_stateful_set(name, namespace, async_req=True)
    >>> result = thread.get()
    :param async_req bool
    :param str name: name of the StatefulSet (required)
    :param str namespace: object name and auth scope, such as for teams and projects (required)
    :param str pretty: If 'true', then the output is pretty printed.
    :param V1DeleteOptions body:
    :param str dry_run: When present, indicates that modifications should not be persisted. An invalid or unrecognized dryRun directive will result in an error response and no further processing of the request. Valid values are: - All: all dry run stages will be processed
    :param int grace_period_seconds: The duration in seconds before the object should be deleted. Value must be non-negative integer. The value zero indicates delete immediately. If this value is nil, the default grace period for the specified type will be used. Defaults to a per object value if not specified. zero means delete immediately.
    :param bool orphan_dependents: Deprecated: please use the PropagationPolicy, this field will be deprecated in 1.7. Should the dependent objects be orphaned. If true/false, the \"orphan\" finalizer will be added to/removed from the object's finalizers list. Either this field or PropagationPolicy may be set, but not both.
    :param str propagation_policy: Whether and how garbage collection will be performed. Either this field or OrphanDependents may be set, but not both. The default policy is decided by the existing finalizer set in the metadata.finalizers and the resource-specific default policy. Acceptable values are: 'Orphan' - orphan the dependents; 'Background' - allow the garbage collector to delete the dependents in the background; 'Foreground' - a cascading policy that deletes all dependents in the foreground.
    :return: V1Status
             If the method is called asynchronously,
             returns the request thread.
    """

我相信设置额外参数 (**kwargs) 的正确方法是使用 key=value 格式，而且 V1DeleteOptions 不是有效参数所以不要将 delete_options 作为参数传递，而应传递 V1DeleteOptions 的每个选项，例如 propagation_policy="Foreground" 和 grace_period_seconds=5:

api_response = k8s_api.delete_namespaced_stateful_set(statefulset_name,namespace,propagation_policy="Foreground", grace_period_seconds=5)

但是，有一种方法可以传递整个 V1DeleteOptions 对象。可以先转成dict再解压：

delete_options = client.V1DeleteOptions(propagation_policy="Foreground", grace_period_seconds=5)
api_response = k8s_api.delete_namespaced_stateful_set(statefulset_name,namespace,**delete_options.do_dict())

使用 python 客户端删除 Kubernetes 资源

Delete Kubernetes resources using python client

kubernetes

kubernetes-python-client