k8s 怎么精准获取deployment关联的pods？

标签获取

我们获取那些pods属于某个deployment时最先想到的可能是通过标签获取，其实这个是不正确的。因为标签并不是唯一的，也就是说不同deployment其实是能有相同标签的。
replicaSets获取

deployment 的产生pod流程如下:  deployment->replicaSets->pod。
deployment 先产生replicaSets, replicaSets再产生pod。所以我们可以根据以下步骤获取到pod。

• 根据标签获取到replicaSets
  
• 根据replicaSets ownerReferences字段进行过滤。就可以得到属于某个deployment的replicaset。
  
• 根据标签获取到pods
  
• 根据pods ownerReferences字段进行过滤。就可以得到属于某个replicaset的pods。
  

注意一点这里有个比较坑的地方，就是deployment在滚动更新中会产生多个replicaset, 假如没有设置revisionHistoryLimit保留汗青的replicaSet的话。那么当新的pod起来了，老的pod在终止时， 此时老的replicaSets会被删除，但是
老的pod又是被老的replicaSets控制的，这个时间去查询deployment 下面的pods就会将这些终止态的pod忽略掉，这在某些系统其实问题很大，就好比我现在做的发布系统，某个发布必须要等老的都终止掉了才能执行下一个业务,那么这个时间其实是有问题的。目前我能想到的办理办法是通过标签筛选出来的pod假如是终止态的话,也归属于这个deployment。各人假如有更好的方法请在下面留言。
代码

1. func (r *Usecase) podsListByDeploymentV2(deployment *appv1.Deployment) ([]v1.Pod, error) {
3.         replicaSetSelector, err := metav1.LabelSelectorAsSelector(deployment.Spec.Selector)
4.         if err != nil {
5.                 return nil, xerrors.WithStack(err)
6.         }
8.         replicaSetListOptions := metav1.ListOptions{LabelSelector: replicaSetSelector.String()}
9.         allReplicaSets, err := r.k8sClient.AppsV1().ReplicaSets(deployment.Namespace).List(context.TODO(), replicaSetListOptions)
10.         if err != nil {
11.                 return nil, xerrors.WithStack(err)
12.         }
13.         ownedReplicaSetsUids := make(map[types.UID]struct{})
14.         for i := range allReplicaSets.Items {
15.                 if !metav1.IsControlledBy(&allReplicaSets.Items[i], deployment) {
16.                         continue
17.                 }
18.                 ownedReplicaSetsUids[allReplicaSets.Items[i].UID] = struct{}{}
19.         }
21.         podSelector, err := metav1.LabelSelectorAsSelector(deployment.Spec.Selector)
22.         if err != nil {
23.                 return nil, xerrors.WithStack(err)
24.         }
25.         podListOptions := metav1.ListOptions{LabelSelector: podSelector.String()}
26.         allPods, err := r.k8sClient.CoreV1().Pods(deployment.Namespace).List(context.TODO(), podListOptions)
27.         if err != nil {
28.                 return nil, xerrors.WithStack(err)
29.         }
31.         //replicaSetUID := replicaSet.UID
32.         rsPods := make([]v1.Pod, 0)
33.         for i, pod := range allPods.Items {
34.                 controllerRef := metav1.GetControllerOf(&allPods.Items[i])
35.                 if controllerRef != nil {
36.                         if _, ok := ownedReplicaSetsUids[controllerRef.UID]; ok {
37.                                 rsPods = append(rsPods, pod)
38.                                 continue
39.                         }
40.                 }
41.                 podStatus := r.k8sRepo.GetPodStatus(&pod)
42.                 if podStatus.Status == repo.TerminatingStatus { // 终止态的也可以认为属于这个deployment
43.                         rsPods = append(rsPods, pod)
44.                         continue
45.                 }
46.         }
48.         return rsPods, nil
50. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。