MongoDB y API de Amadeus

Si uno ya tiene experiencia en RDBSM, una pregunta razonable sería: ¿para que complicarme con una BBDD NoSQL?

En este artículo presento un ejemplo de uso de MongoDB para resolver rápidamente una necesidad específica.

La empresa Amadeus dispone de una API para desarrolladores que permite hacer diferentes tipos de consultas relacionadas con los sectores de aerolíneas, hoteles, etc.

Un ejemplo de consulta a esta API es: amadeus.shopping.flight_offers_search.get()

Esta llamada permite consultar los vuelos disponibles para una ruta y fecha determinadas. La informacion devuelta está en formato JSON.

En el script Python adjunto podemos ver lo fácil que es hacer la llamada a la API e insertar la información devuelta en la colección Amadeus.flight_offers.

from amadeus import Client, ResponseError from pymongo import MongoClient import tkinter as tk from tkinter import scrolledtext # GUI window = tk.Tk() window.title("Amadeus API Demo") window.rowconfigure(0, minsize=600, weight=1) window.columnconfigure(1, minsize=600, weight=1) txt_edit = scrolledtext.ScrolledText(window) txt_edit.grid(row=0, column=1, sticky="nsew") # MongoDB try: mymongo=MongoClient() mydb =mymongo.Amadeus mycol =mydb.flight_offers except pymongo.errors.PyMongoError as e: messagebox.showwarning(title="Error", message="MongoDB error .." + str(e)) #Amadeus API amadeus = Client( client_id=<your client ID>, client_secret=< your secret key> ) def Flight_Offers_Search(AptDep,AptArr,FecVol,Adults,Childs,Infants,Max,NonStop): try: response = amadeus.shopping.flight_offers_search.get( originLocationCode=AptDep, destinationLocationCode=AptArr, departureDate=FecVol, adults=Adults, children=Childs, infants=Infants, max=Max, nonStop=NonStop) except ResponseError as error: print('Error: ' ) ; print(error) txt_edit.insert(tk.INSERT,'\n'+AptDep+'-'+AptArr+' ' + FecVol +'\n') if 'response' in locals(): resp=response.data for flight in resp: try: mycol.insert_one(flight) except pymongo.errors.PyMongoError as e: messagebox.showwarning(title="Error", message="MongoDB error .." + str(e)) du=flight['itineraries'][0]['duration'] pr=flight['price'] ac=flight['validatingAirlineCodes'] txt_edit.insert(tk.INSERT,' Airline: '+ ac[0]+' Duration: ' + du + ' Price: '+pr['total']+' ' + ' Base: ' + pr['base'] + ' Others: ' + str(round(float(pr['total']) - float(pr['base']),2)) + ' ' + pr['currency'] + '\n' ) # Flight Search mycol.drop() AptDep='PMI' ; AptArr='BSL' ; FecVol='2021-08-02' ; Adults=1; Childs=0; Infants=0 ; Max=20 ; NonStop='false' Flight_Offers_Search(AptDep,AptArr,FecVol,Adults,Childs,Infants,Max,NonStop) AptDep='BSL' ; AptArr='PMI' ; FecVol='2021-08-11' ; Adults=1 ; Childs=0; Infants=0 ; Max=20 ; NonStop='false' Flight_Offers_Search(AptDep,AptArr,FecVol,Adults,Childs,Infants,Max,NonStop) window.mainloop()

 
No hay necesidad de procesos previos para crear la BBDD ni la colección. Tampoco necesitamos saber la estructura de la información, sólo la insertamos directamente en MongoDB.

 
Una vez que tenemos la colección creada, podemos hacer las consultas que queramos.

En el ejemplo mostrado en la pantalla siguiente, consultamos los vuelos con precio menor a 150€ y sólo nos interesa que nos muestre los campos aerolínea, precio, duración del vuelo y aeropuerto de salida de cada segmento del vuelo:

Hemos encontrado 15 vuelos que cumplen los criterios de la consulta.

Como podemos ver, una solución realmente rápida y eficiente.