针对需要帮助使用Python从API中提取JSON数据并将其加载到SQL表这个问题，本篇文章进行了详细的解答，同时本文还将给你拓展Ansible无法从URL中提取json，但Curl可以我错过了什么？

针对需要帮助使用 Python 从 API 中提取 JSON 数据并将其加载到 SQL 表这个问题，本篇文章进行了详细的解答，同时本文还将给你拓展Ansible 无法从 URL 中提取 json，但 Curl 可以我错过了什么？、JSON API：用 JSON 构建 API 的标准指南中文版、Json:api：如何在 java 中的补丁请求中发送带有数组的 json 文件？我的 json 文件有 JSONArray 而不是 JSONObject、json模块：json.dumps()、json.loads()、json.dump()、json.load()等相关知识，希望可以帮助到你。

• 需要帮助使用 Python 从 API 中提取 JSON 数据并将其加载到 SQL 表
• Ansible 无法从 URL 中提取 json，但 Curl 可以我错过了什么？
• JSON API：用 JSON 构建 API 的标准指南中文版
• Json:api：如何在 java 中的补丁请求中发送带有数组的 json 文件？我的 json 文件有 JSONArray 而不是 JSONObject
• json模块：json.dumps()、json.loads()、json.dump()、json.load()

需要帮助使用 Python 从 API 中提取 JSON 数据并将其加载到 SQL 表

如何解决需要帮助使用 Python 从 API 中提取 JSON 数据并将其加载到 SQL 表

请您帮我编写 Python 逻辑以从 API 中提取 PullJSON 数据并将其直接加载到 sql 表中。

我已经编写了这个 Python 代码，它在平面 JSON 结构中运行良好，但如果 JSON 有子数组则失败。

例如，Sales 可以在附加的单个 JSON 文件中包含一个标题记录和多个行记录。我能够拉取和加载标题数据，但无法加载行数据。

这是我现有的 Python 代码：

import requests
from requests.auth import HTTPBasicAuth
import json
import pandas as pd

Endpoint = "https://api.cin7.com/api"
FullEndpointExtension = "/v1/SalesOrders?order=Id&page=1&rows=250"

User_name = "XXXXX"
Password_key = "YYYYYY"
Authentication = HTTPBasicAuth(User_name,Password_key)
try:
    response = requests.get(Endpoint + FullEndpointExtension,auth = Authentication)
    DataFrame= pd.read_json(response.text)
    DataFrame = DataFrame[[''id'',''createdDate'',''modifiedDate'',''createdBy'',''processedBy'',''isApproved'',''reference'',''memberId'',''firstName'',''lastName'',''company'',''email'',''phone'',''mobile'',''fax'',''deliveryFirstName'',''deliveryLastName'',''deliveryCompany'',''deliveryAddress1'',''deliveryAddress2'',''deliveryCity'',''deliveryState'',''deliveryPostalCode'',''deliveryCountry'',''billingFirstName'',''billingLastName'',''billingCompany'',''billingAddress1'',''billingAddress2'',''billingCity'',''billingPostalCode'',''billingState'',''billingCountry'',''branchId'',''branchEmail'',''projectName'',''trackingCode'',''internalComments'',''productTotal'',''freightTotal'',''freightDescription'',''surcharge'',''surchargeDescription'',''discountTotal'',''discountDescription'',''total'',''currencyCode'',''currencyRate'',''currencySymbol'',''taxStatus'',''taxRate'',''source'',''isVoid'',''memberEmail'',''memberCostCenter'',''memberAlternativeTaxRate'',''costCenter'',''alternativeTaxRate'',''estimatedDeliveryDate'',''salesPersonId'',''salesPersonEmail'',''paymentTerms'',''customerOrderNo'',''voucherCode'',''deliveryInstructions'',''status'',''stage'',''invoiceDate'',''invoiceNumber'',''dispatchedDate'',''logisticsCarrier'',''logisticsstatus'',''distributionBranchId'',''lineItems'']]

#Capture Error Message
except Exception as ErrorMessage:
    Message = str(ErrorMessage)
    print(Message)
else:
    Message = ''Successfully Completed''
    print(Message)
    
DataFrame 


Sample code:
import json
import requests
import pandas as pd
from io import StringIO

response = requests.get("https://api.github.com/events")
DataFrame= pd.read_json(StringIO(response.text))

for I in DataFrame[''actor'']:
    print(DataFrame[''id''],I[''id''],I[''login''])

示例 JSON： [ { “身份证”：111， "createdDate": "2020-09-08T17:58:00Z","修改日期": "2020-09-10T02:01:09Z","createdBy": 0,"processedBy": 99999,“已批准”：真， “参考”：“4000000000”， “会员ID”：1111， "firstName": "内存","lastName": "实时信用卡订单",“公司”： ””， "email": "ram@abc.co.nz","电话": "041411111",“移动的”： ””， "传真": "","deliveryFirstName": "Ram","deliveryLastName": "实时信用卡订单","送货公司": "","deliveryAddress1": "XXXX","deliveryAddress2": " ","deliveryCity": "XXXXX","deliveryState": "昆士兰州","deliveryPostalCode": "XXXXX","deliveryCountry": "澳大利亚","billingFirstName": "Ram","billingLastName": "实时信用卡订单","计费公司": "","billingAddress1": "XXXXXX","billingAddress2": "","billingCity": "XXXXXX","billingPostalCode": "XXXX","billingState": "昆士兰州","billingCountry": "澳大利亚","branchId": 3,"branchEmail": "","项目名称": "ABC",“跟踪代码”： ””， "内部评论": "","productTotal": 29.9500,“运费总计”：0.0000， "货运描述": "",“附加费”：0.0000， "附加费说明": "","discountTotal": 0.0000,"折扣说明": "",“总计”：29.9500， "currencyCode": "澳元",“货币汇率”：1.0， "货币符号": "$","taxStatus": "包含",“税率”：0.1， "source": "API",“自定义字段”：{ “订单_1000”：空， “订单_1001”：空， “订单_1002”：空， “订单_1003”：空， “订单_1004”：空 },“isVoid”：假， "memberEmail": "ram@abc.co.nz",“memberCostCenter”：空， “memberAlternativeTaxRate”：空， “成本中心”： ””， "alternativeTaxRate": "","estimatedDeliveryDate": null,"salesPersonId": 0,"salesPersonEmail": null,“付款条件”： ””， "customerOrderNo": "",“优惠券代码”：空， "deliveryInstructions": "请在接待处离开","状态": "已批准","stage": "已调度","发票日期": "2020-09-08T17:58:00Z",“发票编号”：5011111， "dispatchedDate": "2020-09-08T20:31:00Z","logisticsCarrier": "BCD","物流状态": 10,"distributionBranchId": 0,“行项目”：[ { “身份证”：363， "createdDate": "2020-09-08T17:58:00Z",“交易编号”：267777， "parentId": 199999,“产品编号”：4444， “productOptionId”：333333， "integrationRef": "0",“排序”：1， "code": "T02392","name": "垫灰色",“选项1”： ””， “选项2”：“”， “选项3”：“”， “数量”：1.0， "styleCode": "T02392",“条形码”：空， “大小代码”：空， "lineComments": "",“单位成本”：11.9900， “单价”：14.9500， “折扣”：0.0000， "qtyShipped": 1.0,“持有数量”：0.0， "帐户代码": "","stockControl": "先进先出",“股票运动”：[ { “批次”：空， “数量”：1.0， “串行”：空 } ],“尺寸”：[] },{ “身份证”：365， "createdDate": "2020-09-08T17:58:00Z",“排序”：1， "代码": "A1111",“选项1”： ””， “选项2”：“”， “选项3”：“”， “数量”：1.0， "styleCode": "ABCXYZ",“条码”： ””， “大小代码”：空， "lineComments": "",“单位成本”：11.9900， “单价”：0.0000， “折扣”：0.0000， "qtyShipped": 1.0,"stockControl": "批次",“股票运动”：[ { “批次”：“100”， “数量”：1.0， “串行”：空 } ],{ “身份证”：364， "createdDate": "2020-09-08T17:58:00Z",“交易编号”：2641， “父母ID”：0， “产品编号”：4410， “productOptionId”：4411， "integrationRef": "0",“排序”：2， "code": "DELIVERYFEE","name": "送货费",“选项1”： ””， “选项2”：“”， “选项3”：“”， “数量”：1.0， "styleCode": "DeliveryFee",“单位成本”：0.0000， “单价”：8.0000， “折扣”：0.0000， "qtyShipped": 1.0,“持有数量”：0.0， "accountCode": "ABCXYZ","stockControl": "ABCXYZ",“股票运动”：[]， “尺寸”：[] } ] } ]

解决方法

import json 
import pandas as pd 
from pandas import json_normalize
#https://pandas.pydata.org/pandas-docs/stable/reference/api/pandas.json_normalize.html
#https://www.kaggle.com/jboysen/quick-tutorial-flatten-nested-json-in-pandas

Endpoint = "https://api.cin7.com/api"
FullEndpointExtension = "/v1/SalesOrders?where=id=2666&order=Id&page=1&rows=250"

User_name = "xxxxxx"
Password_key = "xxxxxxx"
Authentication = HTTPBasicAuth(User_name,Password_key)
r = requests.get(Endpoint + FullEndpointExtension,auth = Authentication)

d = json.loads(r.text)

result1=json_normalize(data=d,record_path=''lineItems'',meta=[''id''],errors=''ignore'',meta_prefix=''Header'')
print(result1)