我是spark的新手，我想做一个简单的项目，在这里我示例化一个spark流来监听这个源代码。我有流代码工作，但问题是，在我开始通过套接字接收任何内容之前，我需要向服务器发送以下消息： {"op":"unconfirmed_sub"} 在同一个插座上。是否可以使用pyspark执行此操作？我的代码：

conf = SparkConf()
conf.setAppName("BCStreamApp")

# create spark context with the above configuration

sc = SparkContext(conf=conf)
sc.setLogLevel("ERROR")

# create the Streaming Context from the above spark context with interval size 2 seconds

ssc = StreamingContext(sc, 2)

# setting a checkpoint to allow RDD recovery

ssc.checkpoint("checkpoint_BCApp")

dataStream = ssc.socketTextStream("wss://ws.blockchain.info/inv",80)
dataStream.pprint()

ssc.start()
ssc.awaitTermination()