parse_url

Belirtilen bir bölümü URL'den ayıklar. Anahtar sağlanırsa, ilişkili sorgu parametresi değerini döndürür.

Sözdizimi

from pyspark.sql import functions as sf

sf.parse_url(url, partToExtract, key=None)

Parametreler

Parametre	Türü	Description
url	pyspark.sql.Column veya str	Her biri bir URL'yi temsil eden bir dize sütunu.
partToExtract	pyspark.sql.Column veya str	Her biri URL'den ayıklanan bölümü temsil eden bir dize sütunu.
key	pyspark.sql.Column veya str, isteğe bağlı	Her biri URL'deki bir sorgu parametresinin anahtarını temsil eden bir dize sütunu.

İade

pyspark.sql.Column: Her biri URL'den ayıklanan bölümün değerini temsil eden yeni bir dize sütunu.

Örnekler

Örnek 1: SORGU bölümünü URL'den ayıklama

from pyspark.sql import functions as sf
df = spark.createDataFrame(
  [("https://spark.apache.org/path?query=1", "QUERY")],
  ["url", "part"]
)
df.select(sf.parse_url(df.url, df.part)).show()

+--------------------+
|parse_url(url, part)|
+--------------------+
|             query=1|
+--------------------+

Örnek 2: URL'den belirli bir sorgu parametresinin değerini ayıklama

from pyspark.sql import functions as sf
df = spark.createDataFrame(
  [("https://spark.apache.org/path?query=1", "QUERY", "query")],
  ["url", "part", "key"]
)
df.select(sf.parse_url(df.url, df.part, df.key)).show()

+-------------------------+
|parse_url(url, part, key)|
+-------------------------+
|                        1|
+-------------------------+

Örnek 3: URL'den protokol bölümünü ayıklama

from pyspark.sql import functions as sf
df = spark.createDataFrame(
  [("https://spark.apache.org/path?query=1", "PROTOCOL")],
  ["url", "part"]
)
df.select(sf.parse_url(df.url, df.part)).show()

+--------------------+
|parse_url(url, part)|
+--------------------+
|               https|
+--------------------+

Örnek 4: Url'den konak bölümünü ayıklama

from pyspark.sql import functions as sf
df = spark.createDataFrame(
  [("https://spark.apache.org/path?query=1", "HOST")],
  ["url", "part"]
)
df.select(sf.parse_url(df.url, df.part)).show()

+--------------------+
|parse_url(url, part)|
+--------------------+
|    spark.apache.org|
+--------------------+

Örnek 5: Url'den yol bölümünü ayıklama

from pyspark.sql import functions as sf
df = spark.createDataFrame(
  [("https://spark.apache.org/path?query=1", "PATH")],
  ["url", "part"]
)
df.select(sf.parse_url(df.url, df.part)).show()

+--------------------+
|parse_url(url, part)|
+--------------------+
|               /path|
+--------------------+