logs-test #13
|
@ -34,12 +34,17 @@ func (s SyncToService) syncData() {
|
||||||
|
|
||||||
// handleSyncDataToServiceAppier ...
|
// handleSyncDataToServiceAppier ...
|
||||||
func handleSyncDataToServiceAppier(pattern string, typeData string) {
|
func handleSyncDataToServiceAppier(pattern string, typeData string) {
|
||||||
|
fmt.Println("keyProductPattern", pattern)
|
||||||
|
|
||||||
for {
|
for {
|
||||||
keys, values := redisdb.GetWithPrefixPattern(pattern, limitGetKeyRedis)
|
keys, values := redisdb.GetWithPrefixPattern(pattern, limitGetKeyRedis)
|
||||||
if len(keys) == 0 {
|
if len(keys) == 0 {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fmt.Println("keys:", keys)
|
||||||
|
fmt.Println("values", values)
|
||||||
|
|
||||||
payload := toBytes(values)
|
payload := toBytes(values)
|
||||||
// Convert data
|
// Convert data
|
||||||
switch typeData {
|
switch typeData {
|
||||||
|
|
Loading…
Reference in New Issue