Aller au contenu principal

try_ip_cidr

S’applique à : coché oui Databricks Runtime 18.2 et versions ultérieures

info

Bêta

Cette fonctionnalité est en Bêta. Les administrateurs du Workspace peuvent contrôler l'accès à cette fonctionnalité à partir de la page Previews . Consultez Gérer les aperçus Databricks.

Retourne la représentation canonique d'un bloc CIDR IPv4 ou IPv6. Retourne None au lieu de lever une erreur si l'entrée est invalide.

Pour la fonction SQL correspondante, consultez la fonctiontry_ip_cidr.

Syntaxe

Python
from pyspark.databricks.sql import functions as dbf

dbf.try_ip_cidr(col=<col>)

parameter

parameter

Type

Description

col

pyspark.sql.Column OU str

Une valeur STRING ou BINARY représentant un bloc CIDR IPv4 ou IPv6 valide.

parameter

Type

Description

col

pyspark.sql.Column OU str

Une valeur STRING ou BINARY représentant un bloc CIDR IPv4 ou IPv6 valide.

Exemples

Exemple 1 : Canonicalisez un bloc CIDR IPv4.

Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('192.168.1.5/24',)], ['cidr'])
df.select(dbf.try_ip_cidr('cidr').alias('result')).collect()
Output
[Row(result='192.168.1.0/24')]

Exemple 2 : Canonicaliser un bloc CIDR IPv6.

Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('2001:db8::1/64',)], ['cidr'])
df.select(dbf.try_ip_cidr('cidr').alias('result')).collect()
Output
[Row(result='2001:db8::/64')]

Exemple 3 : une entrée non valide renvoie None.

Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('invalid.ip/24',)], ['cidr'])
df.select(dbf.try_ip_cidr('cidr').alias('result')).collect()
Output
[Row(result=None)]

Exemple 4 : l'entrée None renvoie None.

Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(None,)], 'cidr: string')
df.select(dbf.try_ip_cidr('cidr').alias('result')).collect()
Output
[Row(result=None)]