try_parse_url

Ini adalah versi parse_url khusus yang melakukan operasi yang sama, tetapi mengembalikan nilai NULL alih-alih meningkatkan kesalahan jika penguraian tidak dapat dilakukan.

Syntax

from pyspark.sql import functions as sf

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

Parameter-parameternya

Pengaturan	Tipe	Description
url	pyspark.sql.Column atau str	Kolom string, masing-masing mewakili URL.
partToExtract	pyspark.sql.Column atau str	Kolom string, masing-masing mewakili bagian untuk diekstrak dari URL.
key	pyspark.sql.Column atau str, opsional	Kolom string, masing-masing mewakili kunci parameter kueri di URL.

Pengembalian Barang

pyspark.sql.Column: Kolom baru string, masing-masing mewakili nilai bagian yang diekstrak dari URL.

Examples

Contoh 1: Mengekstrak bagian kueri dari URL

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

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

Contoh 2: Mengekstrak nilai parameter kueri tertentu dari URL

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.try_parse_url(df.url, df.part, df.key)).show()

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

Contoh 3: Mengekstrak bagian protokol dari URL

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

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

Contoh 4: Mengekstrak bagian host dari URL

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

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

Contoh 5: Mengekstrak bagian jalur dari URL

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

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

Contoh 6: URL tidak valid

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

+-----------------------------+
|try_parse_url(url, part, key)|
+-----------------------------+
|                         NULL|
+-----------------------------+