-
Notifications
You must be signed in to change notification settings - Fork 0
/
sync.php
executable file
·64 lines (53 loc) · 1.66 KB
/
sync.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
#!/usr/bin/php
<?php
require_once("bootstrap.php");
$syncedKeys = [];
$redisTo = $redis['TO'];
$redisFrom = $redis['FROM'];
echo "Checking for keys to sync...\n";
$keysToSync = $redisFrom->keys("*");
echo "Found " . count($keysToSync) . " keys to sync.\n";
$time = microtime(true);
$processed = 0;
shuffle($keysToSync);
foreach($keysToSync as $key){
$processed++;
$type = $redisFrom->type($key);
switch($type){
case 'string':
$redisTo->set($key, $redisFrom->get($key));
break;
case 'list':
$redisTo->lpush($key, $redisFrom->lpop($key));
break;
case 'set':
foreach($redisFrom->smembers($key) as $member) {
$redisTo->sadd($key, $member);
}
break;
case 'hash':
echo "{$key} is a hashmap. Syncing in parts.\n";
foreach($redisFrom->hkeys($key) as $field){
echo " > Setting {$key} -> {$field}\n";
$redisTo->hset($key, $field, $redisFrom->hget($key, $field));
$redisFrom->hdel($key, [$field]);
}
break;
default:
die("Unsupported type: {$type}\n\n\n");
}
if($time < microtime(true) - 1){
echo "Processed: {$processed} of " . count($keysToSync) . "\n";
$time = microtime(true);
}
$syncedKeys[] = $key;
}
if(isset($environment['DELETE_ON_COPY']) && $environment['DELETE_ON_COPY'] == true){
echo "Synced and cleared " . count($syncedKeys) . " keys\n";
if(count($syncedKeys) > 0){
$redisFrom->del($syncedKeys);
}
}else{
echo "Synced " . count($syncedKeys) . " keys\n";
}
sleep(30);