Commit c06279c6 authored by litaolemo's avatar litaolemo

update

parent ad47501b
...@@ -13,10 +13,10 @@ from elasticsearch import Elasticsearch ...@@ -13,10 +13,10 @@ from elasticsearch import Elasticsearch
from meta_base_code.utils.func_get_pv_card_id import get_card_id from meta_base_code.utils.func_get_pv_card_id import get_card_id
import pandas as pd import pandas as pd
redis_client = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN6@172.16.40.133:6379") redis_client = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN6@172.16.40.133:6379", decode_responses=True)
redis_client2 = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN9@172.16.40.173:6379") redis_client2 = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN9@172.16.40.173:6379", decode_responses=True)
redis_client3 = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN12@172.16.40.164:6379") redis_client3 = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN12@172.16.40.164:6379", decode_responses=True)
redis_client4 = redis.StrictRedis.from_url("redis://:XfkMCCdWDIU%ls$h@172.16.50.145:6379") redis_client4 = redis.StrictRedis.from_url("redis://:XfkMCCdWDIU%ls$h@172.16.50.145:6379", decode_responses=True)
es = Elasticsearch([ es = Elasticsearch([
{ {
...@@ -42,10 +42,10 @@ def user_portrait_scan_info(): ...@@ -42,10 +42,10 @@ def user_portrait_scan_info():
print("round: " + str(round)) print("round: " + str(round))
cur, results = redis_client2.scan(cur, keys, 3000) cur, results = redis_client2.scan(cur, keys, 3000)
for key in results: for key in results:
key = str(key, "utf-8") key = key
device_id = key.split(":")[-1] device_id = key.split(":")[-1]
all_count += 1 all_count += 1
print(key)
# if user_portrait_is_empty(device_id): # if user_portrait_is_empty(device_id):
# print(device_id) # print(device_id)
# empty_count += 1 # empty_count += 1
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment