如何使用 Python requests 库发出 post 请求？

Question

我在 Postman 中使用以下过滤器在 Web API 中发出 POST 请求，但我无法在 Python 中使用 requests 库发出简单的 POST 请求。

首先，我正在向该 URL (http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets) 发送一个 POST 请求，其中 Postman 中的以下过滤器应用于正文，并选择了 raw 和 JSON(application/json) 选项。

Filters in Postman

{
  "filter": {
    "filters": [
      {
        "field": "RCA_Assigned_Date",
        "operator": "gte",
        "value": "2017-05-31 00:00:00"
      },
      {
        "field": "RCA_Assigned_Date",
        "operator": "lte",
        "value": "2017-06-04 00:00:00"
      },
      {
        "field": "T_Subcategory",
        "operator": "neq",
        "value": "Temporary Degradation"
      },
      {
        "field": "Issue_Status",
        "operator": "neq",
        "value": "Queued"
      }],
     "logic": "and"
    }
}

存储数据的数据库是Cassandra，根据以下链接Cassandra not equal operator,Cassandra OR operator, Cassandra Between order by operators，Cassandra 不支持 NOT EQUAL TO、OR、BETWEEN 运算符，所以我无法使用除了 AND 之外的这些运算符。

第二，我正在使用以下代码对请求库应用一个简单的过滤器。

import requests
payload = {'field':'T_Subcategory','operator':'neq','value':'Temporary Degradation'}
url = requests.post("http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets",data=payload)

但我得到的是完整的票证数据，而不是只有那些不是临时降级的数据。

第三，系统实际上正在运行，但我们会遇到 2-3 分钟的延迟才能看到数据。逻辑如下：我们有 8 个用户，我们想查看每个用户的所有票证不是临时降级的，然后我们这样做：

def get_json():
    if user_name == "user 001":
        with urllib.request.urlopen(
    "http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets?user_name=user&001",timeout=15) as url:
            complete_data = json.loads(url.read().decode())

    elif user_name == "user 002":
        with urllib.request.urlopen(             
    "http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets?user_name=user&002",timeout=15) as url:
            complete_data = json.loads(url.read().decode())
    return complete_data

def get_tickets_not_temp_degradation(start_date,end_date,complete_):
    return Counter([k['user_name'] for k in complete_data if start_date < dateutil.parser.parse(k.get('DateTime')) < end_date and k['T_subcategory'] != 'Temporary Degradation'])

基本上，我们得到了今年和去年的整套票，然后我们让 Python 按用户过滤完整集，到目前为止只有 10 个用户，这意味着这个过程重复了 10 次，让我毫不奇怪地发现为什么我们会延迟......

我的问题是如何解决 requests 库的这个问题？我正在使用以下链接 Requests library documentation 作为教程来使其正常工作，但似乎我的有效负载没有被读取。

Answer 1

您的 Postman 请求是 JSON 正文。只需在 Python 中重现相同的主体。您的 Python 代码没有发送 JSON，也没有发送与 Postman 示例相同的数据。

对于初学者，通过data 参数发送字典会将字典编码为application/x-www-form-urlencoded 形式，而不是JSON。其次，您似乎发送了一个过滤器。

以下代码完全复制了您的 Postman 帖子：

import requests

filters = {"filter": {
    "filters": [{
        "field": "RCA_Assigned_Date",
        "operator": "gte",
        "value": "2017-05-31 00:00:00"
    }, {
        "field": "RCA_Assigned_Date",
        "operator": "lte",
        "value": "2017-06-04 00:00:00"
    }, {
        "field": "T_Subcategory",
        "operator": "neq",
        "value": "Temporary Degradation"
    }, {
        "field": "Issue_Status",
        "operator": "neq",
        "value": "Queued"
    }],
    "logic": "and"
}}

url = "http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets"
response = requests.post(url, json=filters)

注意filters 在这里是一个Python 数据结构，它被传递给json 关键字参数。使用后者有两件事：

• 将 Python 数据结构编码为 JSON（生成与原始 Postman 正文值完全相同的 JSON 值）。
• 将 Content-Type 标头设置为 application/json（就像您在 Postman 配置中所做的那样，在为正文选择 raw 后，在下拉菜单中选择 JSON 选项）。

requests 否则只是一个 HTTP API，它不能让 Cassandra 比任何其他 HTTP 库做得更多。 urllib.request.urlopen 代码发送GET 请求，并通过以下方式简单地转换为requests：

def get_json():
    url = "http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets"
    response = requests.get(url, params={'user_name': user}, timeout=15)    
    return response.json()

我删除了 if 分支并使用 params 参数替换了它，它将键值对字典转换为正确编码的 URL 查询（将用户名作为 user_name 键传递）。

注意响应中的json() 调用；这负责解码从服务器返回的 JSON 数据。这仍然需要很长时间，您在这里没有太多过滤 Cassandra 数据。

Answer 2

我建议使用json 属性而不是数据。它会为您处理倾销。

import requests

data = {'user_name':'user&001'}
headers = {'Content-Type': 'application/json', 'Accept': 'application/json'}
url = "http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets/"
r = requests.post(url, headers=headers, json=data)

更新，回答问题 3。您使用 urllib 有什么原因吗？对于这个请求，我也会使用 python 请求。

import requests

def get_json():
    r = requests.get("http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets”, params={"user_name": user_name.replace(" ", "&")})

    return r.json

# not sure what you’re doing here, more context/code example would help
def get_tickets_not_temp_degradation(start_date, end_date, complete_):
    return Counter([k['user_name'] for k in complete_data if start_date < dateutil.parser.parse(k.get('DateTime')) < end_date and k['T_subcategory'] != 'Temporary Degradation'])

另外，用户名真的应该是user+001 而不是user&001 或user 001？

Answer 3

您在 url 中发送用户，通过 post 使用它，但这取决于端点的实现方式。你可以试试下面的代码：

import requests
from json import dumps

data = {'user_name':'user&001'}
headers = {'Content-Type': 'application/json', 'Accept': 'application/json'}
url = "http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets/"
r = requests.post(url, headers=headers, data=dumps(data))

Answer 4

我认为，您可以按如下方式使用请求库：

import requests
import json

payload = {'field':'T_Subcategory','operator':'neq','value':'Temporary Degradation'}
url = requests.post("http://10.61.202.98:8081/T/a/api/rows/cat/ect/tickets",data=json.dumps(payload))