Публикация этого здесь, поскольку я совершенно новичок в мире потоковой передачи, и все, что я пытаюсь найти об использовании pyspark для структурированной потоковой передачи, просто показывает, что мы можем по существу использовать для чтения. Нет возможности записать данные в поток кинезиса. Я видел кое-что об использовании kinesis producer library KPL и даже writeStream с приемником кинезиса, но не знал, как использовать его с моим приложением pyspark. Пожалуйста, дайте мне знать, если есть какой-нибудь способ сделать это. Заранее большое спасибо за вашу помощь.