feat:add log

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/RedisService.java

@@ -3,8 +3,10 @@ package com.tzld.piaoquan.recommend.feature.produce.service;
 import com.tzld.piaoquan.recommend.feature.produce.model.DTSConfig;
 import com.tzld.piaoquan.recommend.feature.produce.util.CompressionUtil;
 import com.tzld.piaoquan.recommend.feature.produce.util.JSONUtils;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.collections.MapUtils;
+import org.apache.commons.lang3.RandomUtils;
 import org.apache.commons.lang3.StringUtils;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.Pipeline;
@@ -21,6 +23,7 @@ import java.util.concurrent.TimeUnit;
  *
  * @author dyp
  */
+@Slf4j
 public class RedisService implements Serializable {
     private int port = 6379;
     private String password = "";
@@ -45,6 +48,9 @@ public class RedisService implements Serializable {
             Map<String, String> record = dataIte.next();
             String redisKey = redisKey(record, config);
             String value = JSONUtils.toJson(record);
+            if (RandomUtils.nextDouble() <= 0.001) {
+                log.info("redisKey: {}, value: {}", redisKey, value);
+            }
             batch.put(redisKey, value);
             if (batch.size() >= 1000) {
                 mSet(jedis, batch, expire, TimeUnit.SECONDS);