我有一个RESTful API，我在EC2实例上使用Elasticsearch的实现公开了它，以索引内容语料库。我可以通过在我的终端(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/请求或python/urllib2(不知道哪一个去-一直在使用urllib2，但听说请求更好…)?我是否作为头文件传递?
使用请求和json使之变得简单。
调用API
假设API返回一个JSON，将JSON对象解析为
使用json的Python字典。加载函数
循环字典以提取信息。
请求模块为您提供有用的函数循环成功和失败。
if(Response.ok):将帮助您确定API调用是否成功(响应代码- 200)
Response.raise_for_status()将帮助您获取从API返回的http代码。
下面是进行此类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()
所以你想在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()
使用请求和json使之变得简单。
调用API
假设API返回一个JSON，将JSON对象解析为
使用json的Python字典。加载函数
循环字典以提取信息。
请求模块为您提供有用的函数循环成功和失败。
if(Response.ok):将帮助您确定API调用是否成功(响应代码- 200)
Response.raise_for_status()将帮助您获取从API返回的http代码。
下面是进行此类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()
使用要求:
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返回的响应类型，您可能需要查看响应。Text或response.json()(或者可能是inspect response.json。status_code第一)。请看这里的快速入门文档，尤其是这一部分。
