網(wǎng)站首頁 編程語言 正文
前言
任務描述:
當前有一份excel表格數(shù)據(jù),里面存在缺失值,需要對缺失的數(shù)據(jù)到es數(shù)據(jù)庫中進行查找并對其進行把缺失的數(shù)據(jù)進行補全。
excel表格數(shù)據(jù)如下所示:
一、構建es庫中的數(shù)據(jù)
1.1 創(chuàng)建索引
# 創(chuàng)建physical_examination索引
PUT /physical_examination
{
"settings": {
"index": {
"number_of_shards": "1",
"number_of_replicas": "1"
}
},
"mappings": {
"properties": {
"nums": {
"type": "integer"
},
"name": {
"type": "text"
},
"sex": {
"type": "text"
},
"phone": {
"type": "integer"
},
"result": {
"type": "text"
}
}
}
}
1.2 插入數(shù)據(jù)
【注意:json數(shù)據(jù)不能格式化換行,否則報錯】
# 向physical_examination索引中添加數(shù)據(jù)
POST physical_examination/_bulk
{"index":{"_id":"1"}}
{"nums":1,"name":"劉一","sex":"男","phone":1234567891,"result":"優(yōu)秀"}
{"index":{"_id":"2"}}
{"nums":2,"name":"陳二","sex":"男","phone":1234567892,"result":"優(yōu)秀"}
{"index":{"_id":"3"}}
{"nums":3,"name":"張三","sex":"男","phone":1234567893,"result":"優(yōu)秀"}
{"index":{"_id":"4"}}
{"nums":4,"name":"李四","sex":"男","phone":1234567894,"result":"優(yōu)秀"}
{"index":{"_id":"5"}}
{"nums":5,"name":"王五","sex":"男","phone":1234567895,"result":"優(yōu)秀"}
1.3 查詢數(shù)據(jù)
【注意:默認查詢索引下的所有數(shù)據(jù)】
# 查詢索引中的所有數(shù)據(jù)
GET physical_examination/_search
{
"query": {
"match_all": {}
}
}
二、對excel表格中的數(shù)據(jù)處理操作
2.1 導出es查詢的數(shù)據(jù)
- 方法一:直接在kibana或postman查詢的結果中進行復制粘貼到一個文檔。
- 方法二:使用kibana導出數(shù)據(jù)。
- 方法三:使用postman導出數(shù)據(jù)保存到本地。
使用python處理數(shù)據(jù),獲取需要的數(shù)據(jù)。
示例代碼:
# 讀取json中體檢信息
with open('./data/physical_examination.json', 'r', encoding='utf-8') as f:
data_json = f.read()
print(data_json)
# 處理json數(shù)據(jù)中的異常數(shù)據(jù)
if 'false' in data_json:
data_json = data_json.replace('false', "False")
data_json = eval(data_json)
print(data_json)
print(data_json['hits']['hits'])
print('*' * 100)
valid_data = data_json['hits']['hits']
need_data = []
for data in valid_data:
print(data['_source'])
need_data.append(data['_source'])
print(need_data)
讀取缺失數(shù)據(jù)的excel表格,把缺失的數(shù)據(jù)填補進去。
# 讀取需要填補數(shù)據(jù)的表格
data_xlsx = pd.read_excel('./data/體檢表.xlsx', sheet_name='Sheet1')
# print(data_xlsx)
# 獲取excel表格的行列
row, col = data_xlsx.shape
print(row, col)
# 修改表格中的數(shù)據(jù)
for i in range(row):
bb = data_xlsx.iloc[i]
print(bb['姓名'], bb['手機號'])
if pd.isnull(bb['手機號']):
bb['手機號'] = '666'
for cc in need_data:
if cc['name'] == bb['姓名']:
bb['手機號'] = cc['phone']
data_xlsx.iloc[i, 3] = bb['手機號']
print(bb['姓名'], bb['手機號'])
print("-" * 100)
print(data_xlsx)
將最終處理好的數(shù)據(jù)保存在新建的文件中。
# 保存數(shù)據(jù)到新文件中
data_xlsx.to_excel('./data/new_data.xlsx', sheet_name='Sheet1', index=False, header=True)
完整代碼如下:
import pandas as pd
# 讀取json中體檢信息
with open('./data/physical_examination.json', 'r', encoding='utf-8') as f:
data_json = f.read()
print(data_json)
# 處理json數(shù)據(jù)中的異常數(shù)據(jù)
if 'false' in data_json:
data_json = data_json.replace('false', "False")
data_json = eval(data_json)
print(data_json)
print(data_json['hits']['hits'])
print('*' * 100)
valid_data = data_json['hits']['hits']
need_data = []
for data in valid_data:
print(data['_source'])
need_data.append(data['_source'])
print(need_data)
# 讀取需要填補數(shù)據(jù)的表格
data_xlsx = pd.read_excel('./data/體檢表.xlsx', sheet_name='Sheet1')
# print(data_xlsx)
# 獲取excel表格的行列
row, col = data_xlsx.shape
print(row, col)
# 修改表格中的數(shù)據(jù)
for i in range(row):
bb = data_xlsx.iloc[i]
print(bb['姓名'], bb['手機號'])
if pd.isnull(bb['手機號']):
bb['手機號'] = '666'
for cc in need_data:
if cc['name'] == bb['姓名']:
bb['手機號'] = cc['phone']
data_xlsx.iloc[i, 3] = bb['手機號']
print(bb['姓名'], bb['手機號'])
print("-" * 100)
print(data_xlsx)
# 保存數(shù)據(jù)到新文件中
data_xlsx.to_excel('./data/new_data.xlsx', sheet_name='Sheet1', index=False, header=True)
運行效果,最終處理好的數(shù)據(jù)如下所示:
原文鏈接:https://blog.csdn.net/weixin_44799217/article/details/126559956
相關推薦
- 2022-08-29 Python神器之Pampy模式匹配庫的用法詳解_python
- 2022-05-10 react使用require圖片無法加載
- 2022-12-02 Android系統(tǒng)狀態(tài)欄定制圖標顯示邏輯控制_Android
- 2022-04-09 python的函數(shù)參數(shù)你了解嗎_python
- 2023-12-20 Nacos2.2.3版本運行startup.cmd出現(xiàn)閃退,無錯誤信息解決方法
- 2022-10-26 Android?audio音頻流數(shù)據(jù)異常問題解決分析_Android
- 2022-12-09 python返回多個值與賦值多個值的示例代碼_python
- 2022-12-14 Go語言defer的一些神奇規(guī)則示例詳解_Golang
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細win安裝深度學習環(huán)境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結構-簡單動態(tài)字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支