| | |
|---|
| | | |
|---|
| | | import win32gui |
|---|
| | | |
|---|
| | | from db.redis_manager import RedisUtils |
|---|
| | | from utils import data_export_util |
|---|
| | | import multiprocessing |
|---|
| | | |
|---|
| | |
|---|
| | | try: |
|---|
| | | redis = redis_manager.RedisManager().getRedis() |
|---|
| | | redis.set("test", "1") |
|---|
| | | redis.delete("test") |
|---|
| | | RedisUtils.delete(redis, "test") |
|---|
| | | text.insert(END, "redis连接成功！\n") |
|---|
| | | except: |
|---|
| | | error = "redis连接失败...\n" |
|---|
| | |
|---|
| | | def __draw_pre_data_check(self, frame): |
|---|
| | | def refresh_close_price_data(): |
|---|
| | | redis = redis_manager.RedisManager(0).getRedis() |
|---|
| | | count = len(redis.keys("price-pre-*")) |
|---|
| | | count = len(RedisUtils.keys(redis, "price-pre-*")) |
|---|
| | | sv_num.set("获取到收盘价数量：{}".format(count)) |
|---|
| | | |
|---|
| | | def re_get_close_price(): |
|---|
| | |
|---|
| | | |
|---|
| | | def export_l2_data_origin(code): |
|---|
| | | redis = redis_manager.RedisManager(1).getRedis() |
|---|
| | | keys = redis.keys("big_data-{}-*".format(code)) |
|---|
| | | keys = RedisUtils.keys(redis, "big_data-{}-*".format(code)) |
|---|
| | | try: |
|---|
| | | for k in keys: |
|---|
| | | datas = redis.get(k) |
|---|
