Một tùy chọn là không sử dụng spark-redis, mà là tra cứu trực tiếp trong Redis. Điều này có thể đạt được với df.mapPartitions
hàm số. Bạn có thể tìm thấy một số ví dụ cho Spark DStreams tại đây https://blog.codecentric.de/en/2017/07/lookup-additional-data-in-spark-streaming/. Ý tưởng cho Structural Streaming cũng tương tự. Hãy cẩn thận để xử lý kết nối Redis đúng cách.