如何在pandas.dataframe中插入redis并添加数据?

tp5buhyn  于 2021-06-09  发布在  Redis
关注(0)|答案(0)|浏览(432)

我现在想给redis添加数据。
我的目的是分割数据,并将其一点一点地插入redis。
在redis中插入pandas.dataframe之后,我想添加数据
我们现在已经在redis中插入了dataframe,但是我们不知道如何保存和添加现有的数据。
例如:

log_df_v1 ## DataFrame_v1
session_id                               connect_date     location categories join    page_out
0 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:14:24 경기도        4    0   1
1 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:13 경기도        4    0   0
2 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:10 경기도        4    0   0
3 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:10 경기도        4    0   0
4 62de8537-e79f-4d67-8db5-57a26b89a42d    2020-01-01 00:10:52 경기도        3    0   1

第一步。Dataframe到redis set

r = redis.StrictRedis(host="localhost", port=6379, db=0)
log_dic = log_df_v1.to_dict()

log_set = json.dumps(log_dic,ensure_ascii = False).encode('utf-8')
r.set('log_t1',log_set)

是的
第二步。从redis获取数据,使之成为dataframe

log_get = r.get('log_t1').decode('utf-8')
log_dic = dict(json.loads(log_get))
data_log = pd.DataFrame(log_dic)
data_log
session_id                               connect_date     location categories join    page_out
0 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:14:24 경기도        4    0   1
1 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:13 경기도        4    0   0
2 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:10 경기도        4    0   0
3 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:10 경기도        4    0   0
4 62de8537-e79f-4d67-8db5-57a26b89a42d    2020-01-01 00:10:52 경기도        3    0   1

第三步(问题)。我想向redis添加Dataframe(logdfv2)。但是,我需要保留现有的Dataframe(logdfv1)

log_df_v2 ## DataFrame_v2
session_id                              connect_date        location    categories  join    page_out
 20000    f28e7b23-5ad0-460f-b50e-e6fe0b5edff6    2019-12-29 16:03:39 서울특별시   12  0   0
 20001    e284ca69-333f-4cb8-84c9-485353a4ed74    2019-12-29 16:03:38 경기도 4   0   1
 20002    ea348aa8-aa52-4ee2-84da-f000020c1ecf    2019-12-29 16:03:15 경상북도    1   0   0
 20003    36b9795c-d38f-4ec1-8f49-0eae9cecd0b6    2019-12-29 16:03:12 경상북도    1   0   0
 20004    f83e403e-16f5-4e31-8265-3ad40d9be969    2019-12-29 16:03:12 경상북도    1   0   0

我想要的结果是:

log_get = r.get('log_t1').decode('utf-8')
log_dic = dict(json.loads(log_get))
data_log = pd.DataFrame(log_dic)
data_log
session_id                               connect_date     location categories join    page_out
0 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:14:24 경기도        4    0   1
1 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:13 경기도        4    0   0
2 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:10 경기도        4    0   0
3 5fd1e923-d145-40cc-bf38-3b1156af5eb6    2020-01-01 00:13:10 경기도        4    0   0
4 62de8537-e79f-4d67-8db5-57a26b89a42d    2020-01-01 00:10:52 경기도        3    0   1
 20000    f28e7b23-5ad0-460f-b50e-e6fe0b5edff6    2019-12-29 16:03:39 서울특별시   12  0   0
 20001    e284ca69-333f-4cb8-84c9-485353a4ed74    2019-12-29 16:03:38 경기도 4   0   1
 20002    ea348aa8-aa52-4ee2-84da-f000020c1ecf    2019-12-29 16:03:15 경상북도    1   0   0
 20003    36b9795c-d38f-4ec1-8f49-0eae9cecd0b6    2019-12-29 16:03:12 경상북도    1   0   0
 20004    f83e403e-16f5-4e31-8265-3ad40d9be969    2019-12-29 16:03:12 경상북도    1   0   0

如何将logdfv1和logdfv2插入redis?
我只想在redis上保存数据。
请帮帮我。。。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题