Redis
 sql >> Base de données >  >> NoSQL >> Redis

Existe-t-il un moyen d'écrire une trame de données pyspark dans le cache azur pour redis ?

Vous devez tirer parti de cette bibliothèque :https://github.com/RedisLabs/spark-redis avec le fichier jar associé nécessaire (selon la version de spark+scala que vous utilisez).

Dans mon cas, j'ai installé 3 bocaux sur le cluster d'étincelles (Scala=2.12) dernière étincelle :

  1. spark_redis_2_12_2_6_0.jar
  2. commons_pool2_2_10_0.jar
  3. jedis_3_6_0.jar

Le long de la configuration pour se connecter à redis :

Configuration de la configuration du cluster

spark.redis.auth PASSWORD
spark.redis.port 6379
spark.redis.host xxxx.xxx.cache.windows.net

Assurez-vous d'avoir azure redis 4.0, la bibliothèque peut avoir un problème avec 6.0.Exemple de code à pousser :

    from pyspark.sql.types import StructType, StructField, StringType
schema = StructType([
    StructField("id", StringType(), True),
    StructField("colA", StringType(), True),
    StructField("colB", StringType(), True)
])

data = [
    ['1', '8', '2'],
    ['2', '5', '3'],
    ['3', '3', '1'],
    ['4', '7', '2']
]
df = spark.createDataFrame(data, schema=schema)
df.show()
--------------
(
    df.
    write.
    format("org.apache.spark.sql.redis").
    option("table", "mytable").
    option("key.column", "id").
    save()
)