Invio di richieste HTTP(S)

Questa pagina descrive come inviare richieste HTTP(S) dalla tua app App Engine.

Se hai configurato l'accesso VPC serverless o se utilizzi l'API Sockets, devi interrompere la gestione delle richieste da parte del servizio di recupero URL. URL Fetch causa l'esito negativo delle richieste alla tua rete VPC o all'API Sockets. Dopo aver disattivato il servizio di recupero URL, le richieste HTTP verranno gestite dalla libreria Python standard. Se hai bisogno delle funzionalità fornite da URL Fetch per richieste specifiche, puoi utilizzare direttamente la libreria urlfetch per queste richieste specifiche.

Emettere una richiesta HTTP

Per inviare una richiesta HTTP in uscita, utilizza il metodo urlfetch.fetch. Per una migliore portabilità del codice, puoi anche utilizzare le librerie standard Python urllib, urllib2 o httplib per inviare richieste HTTP. Quando utilizzi queste librerie in App Engine, eseguono richieste HTTP utilizzando il servizio URL Fetch di App Engine. Puoi anche utilizzare la libreria requests di terze parti, a condizione che la configuri per utilizzare URLFetch.

from google.appengine.api import urlfetch

url = 'http://www.google.com/humans.txt'
try:
    result = urlfetch.fetch(url)
    if result.status_code == 200:
        self.response.write(result.content)
    else:
        self.response.status_code = result.status_code
except urlfetch.Error:
    logging.exception('Caught exception fetching url')

try:
    form_data = urllib.urlencode(UrlPostHandler.form_fields)
    headers = {'Content-Type': 'application/x-www-form-urlencoded'}
    result = urlfetch.fetch(
        url='http://localhost:8080/submit_form',
        payload=form_data,
        method=urlfetch.POST,
        headers=headers)
    self.response.write(result.content)
except urlfetch.Error:
    logging.exception('Caught exception fetching url')

import urllib2

url = 'http://www.google.com/humans.txt'
try:
    result = urllib2.urlopen(url)
    self.response.write(result.read())
except urllib2.URLError:
    logging.exception('Caught exception fetching url')

import requests
import requests_toolbelt.adapters.appengine

# Use the App Engine Requests adapter. This makes sure that Requests uses
# URLFetch.
requests_toolbelt.adapters.appengine.monkeypatch()

url = 'http://www.google.com/humans.txt'
response = requests.get(url)
response.raise_for_status()
return response.text

Imposta un timeout della richiesta

Puoi modificare la scadenza predefinita utilizzando la funzione urlfetch.set_default_fetch_deadline(). Questa funzione memorizza la nuova scadenza predefinita in una variabile locale del thread, quindi deve essere impostata per ogni richiesta, ad esempio in un middleware personalizzato.

Disattivare i reindirizzamenti

Se utilizzi URL Fetch, il servizio URL Fetch sottostante segue fino a cinque reindirizzamenti per impostazione predefinita. Questi reindirizzamenti potrebbero inoltrare informazioni sensibili, come le intestazioni di autorizzazione, alla destinazione reindirizzata. Se la tua app non richiede reindirizzamenti HTTP, ti consigliamo di disattivarli.

Per indicare al servizio URL Fetch di non seguire i reindirizzamenti, imposta il parametro follow_redirects del metodo fetch su False.

Emettere una richiesta HTTPS

Per impostazione predefinita, il servizio URL Fetch sottostante convalida il certificato dell'host che contatta e rifiuta le richieste se il certificato non corrisponde. Non è necessario proteggere esplicitamente la richiesta.

Disattiva la convalida del certificato host

Per disattivare la convalida automatica del certificato host in URL Fetch, invia una richiesta HTTPS e imposta il parametro validate_certificate su False quando chiami il metodo urlfetch.fetch().

Emettere una richiesta asincrona

Le richieste HTTP(S) sono sincrone per impostazione predefinita. Per inviare una richiesta asincrona, l'applicazione deve:

1. Crea un nuovo oggetto RPC utilizzando urlfetch.create_rpc(). Questo oggetto rappresenta la chiamata asincrona nelle chiamate di metodo successive.
2. Chiama urlfetch.make_fetch_call() per effettuare la richiesta. Questo metodo accetta l'oggetto RPC e l'URL della richiesta di destinazione come parametri.
3. Chiama il metodo get_result() dell'oggetto RPC. Questo metodo restituisce l'oggetto risultato se la richiesta ha esito positivo e genera un'eccezione se si è verificato un errore durante la richiesta.

I seguenti snippet mostrano come effettuare una richiesta asincrona di base da un'applicazione Python. Innanzitutto, importa la libreria urlfetch dall'SDK App Engine:

from google.appengine.api import urlfetch

Successivamente, utilizza urlfetch per inviare la richiesta asincrona:

rpc = urlfetch.create_rpc()
urlfetch.make_fetch_call(rpc, 'http://www.google.com/')

# ... do other things ...
try:
    result = rpc.get_result()
    if result.status_code == 200:
        text = result.content
        self.response.write(text)
    else:
        self.response.status_int = result.status_code
        self.response.write('URL returned status code {}'.format(
            result.status_code))
except urlfetch.DownloadError:
    self.response.status_int = 500
    self.response.write('Error fetching URL')

Imposta un timeout della richiesta

Per impostare un timeout per la richiesta, imposta il parametro deadline del metodo urlfetch.create_rpc() quando crei l'oggetto RPC.

Utilizzare una funzione di callback

Puoi definire una funzione di callback per l'oggetto RPC. La funzione verrà chiamata quando l'applicazione chiama un metodo sull'oggetto, ad esempio wait(), checksuccess() o get_result(), che fa sì che l'oggetto attenda il completamento della richiesta.

Per utilizzare una funzione di callback per gestire il risultato della chiamata di recupero:

1. Crea una funzione helper per definire l'ambito del callback.
2. Crea una funzione di gestione per gestire il risultato della chiamata di recupero.
3. Imposta l'attributo callback dell'oggetto RPC sulla funzione helper.

Il seguente snippet mostra come richiamare una funzione di callback:

def handle_result(rpc):
    result = rpc.get_result()
    self.response.write(result.content)
    logging.info('Handling RPC in callback: result {}'.format(result))

urls = ['http://www.google.com',
        'http://www.github.com',
        'http://www.travis-ci.org']
rpcs = []
for url in urls:
    rpc = urlfetch.create_rpc()
    rpc.callback = functools.partial(handle_result, rpc)
    urlfetch.make_fetch_call(rpc, url)
    rpcs.append(rpc)

# ... do other things ...

# Finish all RPCs, and let callbacks process the results.

for rpc in rpcs:
    rpc.wait()

logging.info('Done waiting for RPCs')

Emettere una richiesta a un'altra app App Engine

Quando invii una richiesta a un'altra app App Engine, la tua app App Engine deve affermare la propria identità aggiungendo l'intestazione X-Appengine-Inbound-Appid alla richiesta. Se istruisci il servizio URL Fetch a non seguire i reindirizzamenti, App Engine aggiungerà automaticamente questa intestazione alle richieste.

Per indicazioni su come disattivare i reindirizzamenti, vedi Disattivare i reindirizzamenti.

Passaggi successivi

Scopri di più sul servizio di recupero URL, ad esempio le intestazioni inviate in una richiesta di recupero URL in Richieste in uscita.