如何通过pyspark将十六进制数据插入到Cassandra中的blob数据类型列中

from pyspark.sql import SparkSession
from pyspark.sql.functions import udf
from pyspark.sql.types import BinaryType

spark = SparkSession.builder \
    .appName("Insert Hex Data into Cassandra") \
    .config("spark.cassandra.connection.host", "your_cassandra_host") \
    .config("spark.cassandra.connection.port", "your_cassandra_port") \
    .getOrCreate()

hex_to_binary = udf(lambda hex_data: bytes.fromhex(hex_data), BinaryType())

hex_data_df = spark.read.text("path_to_hex_data_file")

binary_data_df = hex_data_df.withColumn("binary_data", hex_to_binary(hex_data_df["value"]))

binary_data_df.write \
    .format("org.apache.spark.sql.cassandra") \
    .options(table="your_cassandra_table", keyspace="your_cassandra_keyspace") \
    .mode("append") \
    .save()