• Python 存储数据到数据库

    数据:

    {
    "ResultCount": 2,
    "Code": "200",
    "DealResult": "[{\"HospitalID\":1385899,\"HospitalCode\":\"H108801565\",\"ExternalID\":\"H108801565\",\"HospitalName\":\"浙商银行股份有限公司医务室\",\"RegionId\":23,\"Region\":\"浙江省\",\"CityId\":\"773\",\"City\":\"杭州市\",\"HospitalGradeId\":0,\"HospitalGrade\":null,\"HospitalTypeId\":0,\"HospitalType\":null,\"StopStatusId\":1,\"StopStatus\":\"启用\",\"StatisticsPropertyId\":0,\"StatisticsProperty\":null,\"CountyId\":0,\"County\":null,\"HospitalPropertyId\":0,\"HospitalProperty\":null,\"CustomerAddress\":\"杭州市下城区庆春路288号\",\"HospitalClassificationId\":null,\"HospitalClassification\":null,\"HospitalGradeUnit\":0,\"DoctorNum\":null,\"CertifiedDoctorNum\":0,\"SpecialistNum\":0,\"SectionOfficeNum\":0,\"BedNum\":null,\"DayOutpatientNum\":0.0,\"YearPurchaseAmount\":0.0,\"ExistingProducts\":null,\"TelePhone\":null,\"ZipCode\":null,\"WebSite\":null,\"LegalPerson\":null,\"Canton\":null,\"IsCountyLevelMedicalId\":0,\"IsCountyLevelMedical\":null,\"ProviderRegisterNO\":null,\"OldName\":null,\"Remark\":\"H108801565\",\"ChannelId\":1,\"Channel\":\"生产企业\",\"CreateUserId\":2003610,\"CreateUser\":\"系统管理员03\",\"CreateTime\":\"2022-11-04 16:27:44\",\"UpdateUserId\":2022302,\"UpdateUser\":\"admingww\",\"UpdateTime\":\"2023-09-26 17:18:50\",\"strHospitalMain\":null,\"strDoctor\":[{\"DoctorID\":1062435,\"Doctor\":\"1\",\"DoctorName\":\"1\",\"DoctorCode\":\"1\",\"PhoneNum\":\"1\",\"PositionName\":\"院长\",\"SectionOfficeName\":\"老干部科\",\"HospitalPhoneNum\":null,\"SectionOffice\":9,\"POSITION\":10}],\"strStoreInfo\":[{\"PKID\":13,\"CustomerID\":1385899,\"Company\":\"山西振东安欣生物制药有限公司\",\"Code\":\"H107285861\",\"NAME\":\"北京祥顺康医药有限公司万顺康诊所\",\"ProductCode\":\"60000004\",\"ProductName\":\"碳酸钙D3颗粒\"}],\"strSectionInfo\":[]},{\"HospitalID\":1385955,\"HospitalCode\":\"H108947538\",\"ExternalID\":\"H108947538\",\"HospitalName\":\"周口市淮阳区人民医院\",\"RegionId\":28,\"Region\":\"河南省\",\"CityId\":\"943\",\"City\":\"周口市\",\"HospitalGradeId\":0,\"HospitalGrade\":null,\"HospitalTypeId\":0,\"HospitalType\":null,\"StopStatusId\":1,\"StopStatus\":\"启用\",\"StatisticsPropertyId\":0,\"StatisticsProperty\":null,\"CountyId\":0,\"County\":null,\"HospitalPropertyId\":0,\"HospitalProperty\":null,\"CustomerAddress\":\"周口市淮阳区106国道与清风路交叉口//周口市淮阳区城关镇民主街2号\",\"HospitalClassificationId\":\"14\",\"HospitalClassification\":\"医院\",\"HospitalGradeUnit\":0,\"DoctorNum\":null,\"CertifiedDoctorNum\":0,\"SpecialistNum\":0,\"SectionOfficeNum\":0,\"BedNum\":null,\"DayOutpatientNum\":0.0,\"YearPurchaseAmount\":0.0,\"ExistingProducts\":null,\"TelePhone\":null,\"ZipCode\":null,\"WebSite\":null,\"LegalPerson\":null,\"Canton\":null,\"IsCountyLevelMedicalId\":0,\"IsCountyLevelMedical\":null,\"ProviderRegisterNO\":\"12411727418746600U\",\"OldName\":\"江苏省淮安市淮阳市第二人民医院,周口市淮阳区第二人民医院,淮阳县公疗医院,淮阳县第二人民医院\",\"Remark\":\"H108947538\",\"ChannelId\":1,\"Channel\":\"生产企业\",\"CreateUserId\":2003610,\"CreateUser\":\"系统管理员03\",\"CreateTime\":\"2023-01-31 17:31:15\",\"UpdateUserId\":2022302,\"UpdateUser\":\"admingww\",\"UpdateTime\":\"2023-09-26 17:13:25\",\"strHospitalMain\":null,\"strDoctor\":[{\"DoctorID\":1062434,\"Doctor\":\"1\",\"DoctorName\":\"1\",\"DoctorCode\":\"1\",\"PhoneNum\":\"1\",\"PositionName\":\"院长\",\"SectionOfficeName\":\"呼吸内科\",\"HospitalPhoneNum\":null,\"SectionOffice\":11,\"POSITION\":10}],\"strStoreInfo\":[{\"PKID\":11,\"CustomerID\":1385955,\"Company\":\"山西振东安欣生物制药有限公司\",\"Code\":\"H109489497\",\"NAME\":\"沈丘县小王楼行政村杨振东卫生室\",\"ProductCode\":\"60000003\",\"ProductName\":\"碳酸钙D₃颗粒\"}],\"strSectionInfo\":[]}]",
    "Msg": "成功"
}

    取DealResult中的数据存入MongoDB数据库:

    首先，需要解析JSON数据，提取出DealResult字段中的数据，可以使用Python的json模块进行解析。然后，将提取出的数据存入MongoDB数据库，可以使用Python的pymongo模块实现。

    1. from pymongo import MongoClient
    2. import json
    3.  
    4. # 连接MongoDB数据库
    5. client = MongoClient('localhost', 27017)
    6. db = client['customer_data']
    7. # 创建一个集合（即 MongoDB 中的表）
    8. collection = db['hospital']
    9.  
    10.  
    11. def test():
    12.     # 解析JSON数据，提取出DealResult字段中的数据
    13.     txt = {
    14.         "ResultCount": 2,
    15.         "Code": "200",
    16.         "DealResult": "[{\"HospitalID\":1385899,\"HospitalCode\":\"H108801565        \",\"ExternalID\":\"H108801565\","
    17.                       "\"HospitalName\":\"浙商银行股份有限公司医务室\",\"RegionId\":23,\"Region\":\"浙江省\",\"CityId\":\"773\","
    18.                       "\"City\":\"杭州市\",\"HospitalGradeId\":0,\"HospitalGrade\":null,\"HospitalTypeId\":0,"
    19.                       "\"HospitalType\":null,\"StopStatusId\":1,\"StopStatus\":\"启用\",\"StatisticsPropertyId\":0,"
    20.                       "\"StatisticsProperty\":null,\"CountyId\":0,\"County\":null,\"HospitalPropertyId\":0,"
    21.                       "\"HospitalProperty\":null,\"CustomerAddress\":\"杭州市下城区庆春路288号\","
    22.                       "\"HospitalClassificationId\":null,\"HospitalClassification\":null,\"HospitalGradeUnit\":0,"
    23.                       "\"DoctorNum\":null,\"CertifiedDoctorNum\":0,\"SpecialistNum\":0,\"SectionOfficeNum\":0,"
    24.                       "\"BedNum\":null,\"DayOutpatientNum\":0.0,\"YearPurchaseAmount\":0.0,\"ExistingProducts\":null,"
    25.                       "\"TelePhone\":null,\"ZipCode\":null,\"WebSite\":null,\"LegalPerson\":null,\"Canton\":null,"
    26.                       "\"IsCountyLevelMedicalId\":0,\"IsCountyLevelMedical\":null,\"ProviderRegisterNO\":null,"
    27.                       "\"OldName\":null,\"Remark\":\"H108801565\",\"ChannelId\":1,\"Channel\":\"生产企业\","
    28.                       "\"CreateUserId\":2003610,\"CreateUser\":\"系统管理员03\",\"CreateTime\":\"2022-11-04 16:27:44\","
    29.                       "\"UpdateUserId\":2022302,\"UpdateUser\":\"admingww\",\"UpdateTime\":\"2023-09-26 17:18:50\","
    30.                       "\"strHospitalMain\":null,\"strDoctor\":[{\"DoctorID\":1062435,\"Doctor\":\"1\","
    31.                       "\"DoctorName\":\"1\",\"DoctorCode\":\"1\",\"PhoneNum\":\"1\",\"PositionName\":\"院长\","
    32.                       "\"SectionOfficeName\":\"老干部科\",\"HospitalPhoneNum\":null,\"SectionOffice\":9,"
    33.                       "\"POSITION\":10}],\"strStoreInfo\":[{\"PKID\":13,\"CustomerID\":1385899,"
    34.                       "\"Company\":\"山西振东安欣生物制药有限公司\",\"Code\":\"H107285861\",\"NAME\":\"北京祥顺康医药有限公司万顺康诊所\","
    35.                       "\"ProductCode\":\"60000004\",\"ProductName\":\"碳酸钙D3颗粒\"}],\"strSectionInfo\":[]},"
    36.                       "{\"HospitalID\":1385955,\"HospitalCode\":\"H108947538\",\"ExternalID\":\"H108947538\","
    37.                       "\"HospitalName\":\"周口市淮阳区人民医院\",\"RegionId\":28,\"Region\":\"河南省\",\"CityId\":\"943\","
    38.                       "\"City\":\"周口市\",\"HospitalGradeId\":0,\"HospitalGrade\":null,\"HospitalTypeId\":0,"
    39.                       "\"HospitalType\":null,\"StopStatusId\":1,\"StopStatus\":\"启用\",\"StatisticsPropertyId\":0,"
    40.                       "\"StatisticsProperty\":null,\"CountyId\":0,\"County\":null,\"HospitalPropertyId\":0,"
    41.                       "\"HospitalProperty\":null,\"CustomerAddress\":\"周口市淮阳区106国道与清风路交叉口//周口市淮阳区城关镇民主街2号\","
    42.                       "\"HospitalClassificationId\":\"14\",\"HospitalClassification\":\"医院\",\"HospitalGradeUnit\":0,"
    43.                       "\"DoctorNum\":null,\"CertifiedDoctorNum\":0,\"SpecialistNum\":0,\"SectionOfficeNum\":0,"
    44.                       "\"BedNum\":null,\"DayOutpatientNum\":0.0,\"YearPurchaseAmount\":0.0,\"ExistingProducts\":null,"
    45.                       "\"TelePhone\":null,\"ZipCode\":null,\"WebSite\":null,\"LegalPerson\":null,\"Canton\":null,"
    46.                       "\"IsCountyLevelMedicalId\":0,\"IsCountyLevelMedical\":null,"
    47.                       "\"ProviderRegisterNO\":\"12411727418746600U\",\"OldName\":\"江苏省淮安市淮阳市第二人民医院,周口市淮阳区第二人民医院,"
    48.                       "淮阳县公疗医院,淮阳县第二人民医院\",\"Remark\":\"H108947538\",\"ChannelId\":1,\"Channel\":\"生产企业\","
    49.                       "\"CreateUserId\":2003610,\"CreateUser\":\"系统管理员03\",\"CreateTime\":\"2023-01-31 17:31:15\","
    50.                       "\"UpdateUserId\":2022302,\"UpdateUser\":\"admingww\",\"UpdateTime\":\"2023-09-26 17:13:25\","
    51.                       "\"strHospitalMain\":null,\"strDoctor\":[{\"DoctorID\":1062434,\"Doctor\":\"1\","
    52.                       "\"DoctorName\":\"1\",\"DoctorCode\":\"1\",\"PhoneNum\":\"1\",\"PositionName\":\"院长\","
    53.                       "\"SectionOfficeName\":\"呼吸内科\",\"HospitalPhoneNum\":null,\"SectionOffice\":11,"
    54.                       "\"POSITION\":10}],\"strStoreInfo\":[{\"PKID\":11,\"CustomerID\":1385955,"
    55.                       "\"Company\":\"山西振东安欣生物制药有限公司\",\"Code\":\"H109489497\",\"NAME\":\"沈丘县小王楼行政村杨振东卫生室\","
    56.                       "\"ProductCode\":\"60000003\",\"ProductName\":\"碳酸钙D₃颗粒\"}],            \"strSectionInfo\":[]}]",
    57.         "Msg": "成功"
    58.     }
    59. result = json.loads(txt['DealResult'])
    60.     # 将提取出的数据存入MongoDB数据库
    61.     for item in result:
    62.         collection.insert_one(item)
    63.     return 'ok, 数据存入成功', type(result)
    64.  
    65.  
    66. print(test())

     使存入的MongoDB数据库中的数据不重复

    1. from pymongo import MongoClient
    2. import requests
    3. import json
    4.  
    5. # 连接MongoDB数据库
    6. client = MongoClient('localhost', 27017)
    7. db = client['customer']
    8. # 创建一个集合（即 MongoDB 中的表）
    9. collection = db['hospital_pms']
    10.  
    11.  
    12. def test():
    13.     url = 'http://172.16.21.3:5013/PMSAPI/MasterData/GetHospitalMainInfo'
    14.     data = {
    15.         "page": 1,
    16.         "pageSize": "10",
    17.         "UpdateTimeStart": "2023-09-26",
    18.         # "UpdateTimeStart": "2021-01-01",
    19.         "UpdateTimeEnd": "2023-09-27"
    20.     }
    21.     # 传入参数
    22.     response = requests.post(url, data=data)
    23.     # 解析JSON数据，提取出DealResult字段中的数据
    24.     results = json.loads(response.json()['DealResult'])
    25.     ids = []
    26.     # 将提取出的数据存入MongoDB数据库
    27.     for result in results:
    28.         result = collection.update_one(
    29.             {"HospitalID": result["HospitalID"]},   # 按照HospitalID字段查询是否存在记录
    30.             {"$set": result},                       # 更新或插入的数据
    31.             upsert=True                             # 插入不存在的记录
    32.         )
    33.         ids.append(result.upserted_id)
    34.         print(result.modified_count, "updated")  # 输出更新记录数
    35.         print(result.upserted_id, "inserted")  # 输出插入记录的ID
    36.     return 'ok, 数据存入成功', ids
    37.  
    38.  
    39. print(test())

  • 相关阅读:
    stm32f103+HC-SR04+ssd1306实现超声波测距
    530. 二叉搜索树的最小绝对差
    软件测试面试题合集
    数据结构：基于数组实现简单的数据缓存区（简单队列）
    allatori8.0文档翻译-第二步-基础应用混淆
    计算机毕业设计django基于python的热门短视频推荐系统(源码+系统+mysql数据库+Lw文档）
    python3 重启docker方法
    使用未定义的class错误【不完整类型的使用】
    2023年Q3线上生鲜水产数据分析：市场不景气，销额同比下滑44%
    实例分割算法综述
  • 原文地址：https://blog.csdn.net/qq1226546902/article/details/133860205