Redis Data Migration Method III

Cette méthode a été élaborée parShellScript,Obtenir un par unkey,SelonKEYDifférents types un par unKEYMigration,Lent.,L'utilisation en grandes quantités n'est pas recommandée

#!/bin/bash

#Adresse
host='127.0.0.1'
#Port Source
src_port=7000
#Port de destination
dest_port=8000
#Compteur,Compter le nombre de migrationsKEY,Impression finale
cnt=0


#Traverser toutKEY
for k in `redis-cli -h $host -p $src_port keys "*"`
do
        data_type=`redis-cli -h $host -p $src_port type $k`
        #Juger un par unKEYAprès le type,Oui.KEYLisez - le.,Écrire à la cibleRedis
        case $data_type in 
        'string')
                v=`redis-cli -h $host -p $src_port get $k`
                redis-cli -h $host -p $dest_port set $k $v
                ;;
        'list')
                values=`redis-cli -h $host -p $src_port lrange $k 0 -1`
                redis-cli -h $host -p $dest_port lpush $k $values
                ;;
        'set')
                values=`redis-cli -h $host -p $src_port smembers $k`
                redis-cli -h $host -p $dest_port sadd $k $values
                ;;

        'hash')
                for key in `redis-cli -h $host -p $src_port hkeys $k`
                do
                        hvalue=`redis-cli -h $host -p $src_port hget $k $key`
                        redis-cli -h $host -p $dest_port hset $k $key $hvalue
                done
                ;;
        *)
                echo "not known type"
                ;;
        esac
        let cnt++
done
# Imprimer la migration KEY
echo $cnt

Mise en œuvre

bak]# sh m.sh
OK
(integer) 1
(integer) 1
(integer) 1
OK
OK
OK
(integer) 3
OK
OK
(integer) 1
OK
(integer) 5
OK
OK
(integer) 1
(integer) 1
OK
15

Validation des résultats

 bak]# redis-cli -h 127.0.0.1 -p 8000 keys '*' 
 1) "k2"
 2) "sname"
 3) "k10"
 4) "k4"
 5) "hclass1"
 6) "k8"
 7) "k9"
 8) "hclass2"
 9) "k3"
10) "k6"
11) "lname"
12) "hclass3"
13) "k1"
14) "k7"
15) "k5"

Note:： Voir en lignepythonScript, Parce que je fais python Erreur de code ,Remplacer manuellement parshellScript;

Les intérêts peuvent être mentionnés：

#coding=utf-8
import redis
redis_from = redis.StrictRedis(host='127.0.0.1', port=6379, db=10)
redis_to = redis.StrictRedis(host='127.0.0.1', port=6379, db=0)
if __name__ == '__main__':
    cnt = 0
    for k in redis_from.keys():
        data_type = redis_from.type(k)
        if data_type == 'string':
            v = redis_from.get(k)
            redis_to.set(k, v)
        elif data_type == 'list':
            values = redis_from.lrange(k, 0, -1)
            redis_to.lpush(k, values)
        elif data_type == 'set':
            values = redis_from.smembers(k)
            redis_to.sadd(k, values)
        elif data_type == 'hash':
            keys = redis_from.hkeys(k)
            for key in keys:
                value = redis_from.hget(k, key)
                redis_to.hset(k, key, value)
        else:
            print 'not known type'
        cnt = cnt + 1
    print 'total', cnt