Flight service nei notebook R

È possibile utilizzare Flight service e il protocollo Flight Apache Arrow per leggere e scrivere dati nelle risorse di un progetto o di uno spazio. Questi dati possono essere file presenti nell'archivio associato al progetto o allo spazio corrente, oppure dati a cui si accede tramite una connessione a un database.

Caricamento dei dati con codice generato utilizzando Flight service

Quando si caricano i dati da una risorsa di progetto in un notebook, il codice generato utilizza pyarrow per richiamare ` Flight service `, sebbene le chiamate alla pyarrow funzione non siano visibili poiché sono racchiuse in funzioni di livello superiore fornite da un'altra libreria denominata itc_utils.

Questa itc_utils libreria è preinstallata in tutti gli ambienti di esecuzione per notebook forniti da IBM al fine di ridurre le dimensioni del codice e renderlo più leggibile. Per raggiungere questo obiettivo, la itc_utils libreria sfrutta le informazioni provenienti dall'ambiente di esecuzione e dalla ibm_watson_studio_lib libreria.

Un altro vantaggio significativo del codice generato è che la richiesta di dati presenta proprietà specifiche, ovvero «connection_name», «connected_data_name» o «data_name», a seconda del tipo di risorsa per cui si genera il codice. itc_utils converte queste proprietà in un asset_id, oltre a un project_id o space_id, prima di creare un descrittore di volo.

Esempio del codice generato per caricare i dati:

library("reticulate")
library("arrow")

itcfs <- import("itc_utils.flight_service")

readClient <- itcfs$get_flight_client()

nb_data_request = dict(
    "connection_name" = "MyConnection",
    "interaction_properties" = dict(
         "row_limit" = 500,
        "schema_name" = "<schema>",
        "table_name" = "<table>"
    )
)

flightInfo <- itcfs$get_flight_info(readClient, nb_data_request=nb_data_request)

tables <- itcfs$read_tables(readClient, flightInfo, timeout=240)
data_df_1 <- as.data.frame(tables[[1]])
head(data_df_1)

È possibile utilizzare le funzioni fornite da itc_utils per estendere il codice che utilizza la pyarrow libreria. Poiché itc_utils si basa su pyarrow, puoi selezionare funzioni specifiche di itc_utils e integrarle nel tuo pyarrow codice.

Nota:

La itc_utils libreria mette a disposizione funzioni di supporto che puoi utilizzare per rendere i tuoi programmi più leggibili. IBM. può rimuovere questa libreria in qualsiasi momento, qualora lo ritenga necessario, e le funzionalità possono essere modificate senza preavviso.

Per un elenco delle itc_utils funzioni che possono semplificare notevolmente lo sviluppo del codice, consulta la sezione "Utilizzo itc_utils con il proprio codice ". Si noti che la sintassi dei descrittori e delle richieste, così come tutte le chiamate di funzione riportate negli esempi, è espressa in notazione " Python ", che dovrà essere opportunamente adattata per R.

Se si verificano errori di timeout, consultare la sezione "Suggerimenti e consigli sui timeout". Anche in questo caso, tutte le chiamate di funzione riportate negli esempi sono scritte nella notazione " Python ", che dovrai adattare di conseguenza per R.

Ulteriori informazioni