aks-preview: Change NAT gateway V2 outbound IPs/prefixes to comma-separated

Change --nat-gateway-outbound-ips and --nat-gateway-outbound-ip-prefixes
from space-separated (nargs='+') to comma-separated string input, matching
the existing load balancer outbound IP parameter pattern
(--load-balancer-outbound-ips).

Before: az aks create --nat-gateway-outbound-ips id1 id2
After:  az aks create --nat-gateway-outbound-ips id1,id2

Author: christine33-creator

src/aks-preview/HISTORY.rst

@@ -12,6 +12,10 @@ To release a new version, please select a new version number (usually plus 1 to
 Pending
 +++++++
 
+20.0.0b1
++++++++
+* [Breaking Change] `az aks create/update`: Change `--nat-gateway-outbound-ips` and `--nat-gateway-outbound-ip-prefixes` to use comma-separated values, consistent with load balancer outbound IP parameters.
+
 19.0.0b29
 +++++++
 * Add MIG (Multi-Instance GPU) strategy option to node pool property in `az aks nodepool add` and `az aks nodepool update`.

src/aks-preview/azext_aks_preview/_natgateway.py

@@ -91,14 +91,16 @@ def configure_nat_gateway_profile(
 
     if outbound_ip_ids is not None:
         ManagedClusterNATGatewayProfileOutboundIPs = models.ManagedClusterNATGatewayProfileOutboundIPs
+        ip_id_list = [x.strip() for x in outbound_ip_ids.split(',') if x.strip()]
         profile.outbound_i_ps = ManagedClusterNATGatewayProfileOutboundIPs(
-            public_i_ps=outbound_ip_ids
+            public_i_ps=ip_id_list
         )
 
     if outbound_ip_prefix_ids is not None:
         ManagedClusterNATGatewayProfileOutboundIPPrefixes = models.ManagedClusterNATGatewayProfileOutboundIPPrefixes
+        prefix_id_list = [x.strip() for x in outbound_ip_prefix_ids.split(',') if x.strip()]
         profile.outbound_ip_prefixes = ManagedClusterNATGatewayProfileOutboundIPPrefixes(
-            public_ip_prefixes=outbound_ip_prefix_ids
+            public_ip_prefixes=prefix_id_list
         )
 
     return profile

src/aks-preview/azext_aks_preview/_params.py

@@ -691,8 +691,7 @@ def load_arguments(self, _):
                 "--nat-gateway-outbound-ips",
                 "--nat-gw-ips",
             ],
-            nargs="+",
-            help="Space-separated public IP resource IDs for the "
+            help="Comma-separated public IP resource IDs for the "
                  "cluster NAT gateway. V2 only.",
         )
         c.argument(
@@ -701,8 +700,7 @@ def load_arguments(self, _):
                 "--nat-gateway-outbound-ip-prefixes",
                 "--nat-gw-prefixes",
             ],
-            nargs="+",
-            help="Space-separated public IP prefix resource IDs "
+            help="Comma-separated public IP prefix resource IDs "
                  "for the cluster NAT gateway. V2 only.",
         )
         c.argument(
@@ -1329,8 +1327,7 @@ def load_arguments(self, _):
                 "--nat-gateway-outbound-ips",
                 "--nat-gw-ips",
             ],
-            nargs="+",
-            help="Space-separated public IP resource IDs for the "
+            help="Comma-separated public IP resource IDs for the "
                  "cluster NAT gateway. V2 only.",
         )
         c.argument(
@@ -1339,8 +1336,7 @@ def load_arguments(self, _):
                 "--nat-gateway-outbound-ip-prefixes",
                 "--nat-gw-prefixes",
             ],
-            nargs="+",
-            help="Space-separated public IP prefix resource IDs "
+            help="Comma-separated public IP prefix resource IDs "
                  "for the cluster NAT gateway. V2 only.",
         )
         c.argument("network_dataplane", arg_type=get_enum_type(network_dataplanes))

src/aks-preview/azext_aks_preview/tests/latest/test_natgateway.py

@@ -122,24 +122,51 @@ def test_v2_with_managed_outbound_ipv6_count(self):
         self.assertEqual(profile.idle_timeout_in_minutes, 30)
 
     def test_v2_with_outbound_ip_ids(self):
-        ip_ids = ["/subscriptions/sub1/resourceGroups/rg1/providers/Microsoft.Network/publicIPAddresses/ip1"]
+        ip_ids = "/subscriptions/sub1/resourceGroups/rg1/providers/Microsoft.Network/publicIPAddresses/ip1"
         profile = natgateway.create_nat_gateway_profile(
             None, None, models=self.nat_gateway_models,
             outbound_ip_ids=ip_ids,
         )
         self.assertIsNotNone(profile)
         self.assertEqual(len(profile.outbound_i_ps.public_i_ps), 1)
-        self.assertEqual(profile.outbound_i_ps.public_i_ps[0], ip_ids[0])
+        self.assertEqual(profile.outbound_i_ps.public_i_ps[0], ip_ids)
+
+    def test_v2_with_multiple_outbound_ip_ids(self):
+        ip_ids = "/sub/rg/ip1,/sub/rg/ip2"
+        profile = natgateway.create_nat_gateway_profile(
+            None, None, models=self.nat_gateway_models,
+            outbound_ip_ids=ip_ids,
+        )
+        self.assertEqual(len(profile.outbound_i_ps.public_i_ps), 2)
+        self.assertEqual(profile.outbound_i_ps.public_i_ps[0], "/sub/rg/ip1")
+        self.assertEqual(profile.outbound_i_ps.public_i_ps[1], "/sub/rg/ip2")
+
+    def test_v2_with_outbound_ip_ids_whitespace(self):
+        ip_ids = "/sub/rg/ip1, /sub/rg/ip2"
+        profile = natgateway.create_nat_gateway_profile(
+            None, None, models=self.nat_gateway_models,
+            outbound_ip_ids=ip_ids,
+        )
+        self.assertEqual(len(profile.outbound_i_ps.public_i_ps), 2)
+        self.assertEqual(profile.outbound_i_ps.public_i_ps[1], "/sub/rg/ip2")
+
+    def test_v2_with_outbound_ip_ids_trailing_comma(self):
+        ip_ids = "/sub/rg/ip1,"
+        profile = natgateway.create_nat_gateway_profile(
+            None, None, models=self.nat_gateway_models,
+            outbound_ip_ids=ip_ids,
+        )
+        self.assertEqual(len(profile.outbound_i_ps.public_i_ps), 1)
 
     def test_v2_with_outbound_ip_prefix_ids(self):
-        prefix_ids = ["/subscriptions/sub1/resourceGroups/rg1/providers/Microsoft.Network/publicIPPrefixes/prefix1"]
+        prefix_ids = "/subscriptions/sub1/resourceGroups/rg1/providers/Microsoft.Network/publicIPPrefixes/prefix1"
         profile = natgateway.create_nat_gateway_profile(
             None, None, models=self.nat_gateway_models,
             outbound_ip_prefix_ids=prefix_ids,
         )
         self.assertIsNotNone(profile)
         self.assertEqual(len(profile.outbound_ip_prefixes.public_ip_prefixes), 1)
-        self.assertEqual(profile.outbound_ip_prefixes.public_ip_prefixes[0], prefix_ids[0])
+        self.assertEqual(profile.outbound_ip_prefixes.public_ip_prefixes[0], prefix_ids)
 
     def test_v2_only_ipv6_count(self):
         profile = natgateway.create_nat_gateway_profile(
@@ -171,7 +198,7 @@ def test_v2_update_with_ipv6_count(self):
 
     def test_v2_update_with_outbound_ip_ids(self):
         origin_profile = self.nat_gateway_models.ManagedClusterNATGatewayProfile(idle_timeout_in_minutes=4)
-        ip_ids = ["/subscriptions/sub1/resourceGroups/rg1/providers/Microsoft.Network/publicIPAddresses/ip1"]
+        ip_ids = "/subscriptions/sub1/resourceGroups/rg1/providers/Microsoft.Network/publicIPAddresses/ip1"
         profile = natgateway.update_nat_gateway_profile(
             None, None, origin_profile, models=self.nat_gateway_models,
             outbound_ip_ids=ip_ids,
@@ -196,11 +223,11 @@ def test_only_ipv6_count(self):
         self.assertTrue(result)
 
     def test_only_outbound_ip_ids(self):
-        result = natgateway.is_nat_gateway_profile_provided(None, None, outbound_ip_ids=["/sub/ip1"])
+        result = natgateway.is_nat_gateway_profile_provided(None, None, outbound_ip_ids="/sub/ip1")
         self.assertTrue(result)
 
     def test_only_outbound_ip_prefix_ids(self):
-        result = natgateway.is_nat_gateway_profile_provided(None, None, outbound_ip_prefix_ids=["/sub/prefix1"])
+        result = natgateway.is_nat_gateway_profile_provided(None, None, outbound_ip_prefix_ids="/sub/prefix1")
         self.assertTrue(result)
 
     def test_all_none(self):

src/aks-preview/setup.py

@@ -9,7 +9,7 @@
 
 from setuptools import find_packages, setup
 
-VERSION = "19.0.0b29"
+VERSION = "20.0.0b1"
 
 CLASSIFIERS = [
     "Development Status :: 4 - Beta",