Selly-Modules
/
appier
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

logs-test

This commit is contained in:
Minh Nguyen 2022-03-25 14:31:03 +07:00
parent 46f77e3292
commit 37199872b0
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sync_to_service.go
View File

@ -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 {