Создание запроса к RESTful API с использованием python

221

У меня есть RESTful API, который я раскрыл, используя реализацию Elasticsearch на экземпляре EC2 для индексации совокупности содержимого. Я могу запросить поиск, запустив следующее из моего терминала (MacOSX):

curl -XGET 'http://ES_search_demo.com/document/record/_search?pretty=true' -d '{
  "query": {
    "bool": {
      "must": [
        {
          "text": {
            "record.document": "SOME_JOURNAL"
          }
        },
        {
          "text": {
            "record.articleTitle": "farmers"
          }
        }
      ],
      "must_not": [],
      "should": []
    }
  },
  "from": 0,
  "size": 50,
  "sort": [],
  "facets": {}
}'

Как превратить вышеуказанное в запрос API с помощью python/requestsили python/urllib2(не уверен, какой из них использовать - использовал urllib2, но слышал, что запросы лучше ...)? Я передаю в качестве заголовка или иначе?

user7289
источник

Ответы:

340

Используя запросы :

import requests
url = 'http://ES_search_demo.com/document/record/_search?pretty=true'
data = '''{
  "query": {
    "bool": {
      "must": [
        {
          "text": {
            "record.document": "SOME_JOURNAL"
          }
        },
        {
          "text": {
            "record.articleTitle": "farmers"
          }
        }
      ],
      "must_not": [],
      "should": []
    }
  },
  "from": 0,
  "size": 50,
  "sort": [],
  "facets": {}
}'''
response = requests.post(url, data=data)

В зависимости от того, какой ответ возвращает ваш API, вы, вероятно, захотите посмотреть response.textили response.json()(или, возможно, проверить response.status_codeсначала). Посмотрите быстрые документы здесь , особенно этот раздел .

andersschuller
источник
3
я думаю, что это должно быть: response =
запросы.пост
8
«request.get» не принимает параметр «data». Он может принимать необязательный параметр «params», который обычно является строкой запроса, содержащей слово dict. Если для получения данных необходима полезная нагрузка (например, приведенный в примере пример), необходимо использовать «request.post». Кроме того, использование библиотеки «json» облегчает анализ ответа json.
HVS
4
@ParveenShukhala «Запросы официально поддерживают Python 2.6–2.7 и 3.3–3.5 и отлично работают на PyPy». - pypi.python.org/pypi/requests
Данио
2
Поскольку вы отправляете JSON, вы можете использовать параметр json, а не данные, например так: response = arguments.post (url, json = data)
Марк Чорли
101

Использование запросов и JSON делает это просто.

  1. Вызовите API
  2. Предполагая, что API возвращает JSON, проанализируйте объект JSON в тексте Python, используя json.loadsфункцию
  3. Переберите диктовку для извлечения информации.

Модуль запросов предоставляет вам полезную функцию для цикла для успеха и неудачи.

if(Response.ok): поможет вам определить, успешен ли ваш вызов API (код ответа - 200)

Response.raise_for_status() поможет вам получить код http, который возвращается из API.

Ниже приведен пример кода для выполнения таких вызовов API. Также можно найти в github . Код предполагает, что API использует дайджест-аутентификацию. Вы можете пропустить это или использовать другие соответствующие модули аутентификации для аутентификации клиента, вызывающего API.

#Python 2.7.6
#RestfulClient.py

import requests
from requests.auth import HTTPDigestAuth
import json

# Replace with the correct URL
url = "http://api_url"

# It is a good practice not to hardcode the credentials. So ask the user to enter credentials at runtime
myResponse = requests.get(url,auth=HTTPDigestAuth(raw_input("username: "), raw_input("Password: ")), verify=True)
#print (myResponse.status_code)

# For successful API call, response code will be 200 (OK)
if(myResponse.ok):

    # Loading the response data into a dict variable
    # json.loads takes in only binary or string variables so using content to fetch binary content
    # Loads (Load String) takes a Json file and converts into python data structure (dict or list, depending on JSON)
    jData = json.loads(myResponse.content)

    print("The response contains {0} properties".format(len(jData)))
    print("\n")
    for key in jData:
        print key + " : " + jData[key]
else:
  # If response code is not ok (200), print the resulting http error code with description
    myResponse.raise_for_status()
HVS
источник
2
Последняя часть с итерацией по ключам не всегда будет работать, потому что документ JSON может иметь массив в качестве элемента верхнего уровня. Таким образом, было бы ошибкой пытаться получитьjData[key]
Денис The Menace
@DenisTheMenace, если это массив, как мне его обойти?
qasimalbaqali
@qasimalbaqali так же, как вы перебираете словарь. Но элементы массива будут простыми jData, а неjData[key]
Denis The Menace
Примечание: если ваш API возвращает большой ответ JSON, вы можете напечатать его так: print(json.dumps(jData, indent=4, sort_keys=True))
Marco
2
Под python3 выкладывалось следующее: «JSON должен быть str, а не bytes». Это исправлено путем декодирования выходных данных, т.е. json.loads (myResponse.content.decode ('utf-8')). Также вы должны обернуть ключ и ключ jData с помощью str (), чтобы, когда RESTful API возвращал целые числа, он не жаловался.
Миркулес
11

Таким образом, вы хотите передать данные в теле запроса GET, лучше сделать это в вызове POST. Вы можете достичь этого, используя оба запроса.

Необработанный запрос

GET http://ES_search_demo.com/document/record/_search?pretty=true HTTP/1.1
Host: ES_search_demo.com
Content-Length: 183
User-Agent: python-requests/2.9.0
Connection: keep-alive
Accept: */*
Accept-Encoding: gzip, deflate

{
  "query": {
    "bool": {
      "must": [
        {
          "text": {
            "record.document": "SOME_JOURNAL"
          }
        },
        {
          "text": {
            "record.articleTitle": "farmers"
          }
        }
      ],
      "must_not": [],
      "should": []
    }
  },
  "from": 0,
  "size": 50,
  "sort": [],
  "facets": {}
}

Пример звонка с запросами

import requests

def consumeGETRequestSync():
data = '{
  "query": {
    "bool": {
      "must": [
        {
          "text": {
            "record.document": "SOME_JOURNAL"
          }
        },
        {
          "text": {
            "record.articleTitle": "farmers"
          }
        }
      ],
      "must_not": [],
      "should": []
    }
  },
  "from": 0,
  "size": 50,
  "sort": [],
  "facets": {}
}'
url = 'http://ES_search_demo.com/document/record/_search?pretty=true'
headers = {"Accept": "application/json"}
# call get service with headers and params
response = requests.get(url,data = data)
print "code:"+ str(response.status_code)
print "******************"
print "headers:"+ str(response.headers)
print "******************"
print "content:"+ str(response.text)

consumeGETRequestSync()
Гвир
источник
получил там мертвую ссылку
user3157940
4
Переменная headers должна использоваться: запросы.get (... headers = headers, ....)
Маркус Мейер
9

Ниже приведена программа для выполнения остальных API в Python-

import requests
url = 'https://url'
data = '{  "platform": {    "login": {      "userName": "name",      "password": "pwd"    }  } }'
response = requests.post(url, data=data,headers={"Content-Type": "application/json"})
print(response)
sid=response.json()['platform']['login']['sessionId']   //to extract the detail from response
print(response.text)
print(sid)
Шашанк Г
источник