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