Fusion et interrogation de données à partir de watsonx.data
Découvrez comment interroger et fusionner des données à partir d'une NPSaaS et d'une table de lac de données.
Avant de commencer
Dans les exemples, on utilise le " données de l'enregistrement Trajet en taxi à New York et le " {: external} disponibles publiquement pour les taxis jaunes en janvier 2021 et 2022. Pour suivre cet exemple, assurez-vous que les données se trouvent dans un bucket S3 accessible et que la table a été chargée dans watsonx.data dans une table Apache Iceberg dans le serveur Hive Metastore (HMS).
Exécutez une requête inter-base de données avec la table dans la base de données du lac de données.
-
Pour identifier l'année qui a eu le plus de passagers, courir:
Exemple :
LOCALDB.ADMIN(ADMIN)=> select ( select sum(PASSENGER_COUNT) from YELLOW_TAXI_JANUARY_2022_LOADED) as "passengers 2022",( select sum(PASSENGER_COUNT) from MYLAKE.TAXIDATA.YELLOW_TAXI_JANUARY_2021) as "passengers 2021";Sortie :
passengers 2022 | passengers 2021 -----------------+----------------- 3324167 | 1794615 (1 row) -
Pour comparer le nombre de passagers ayant voyagé entre 1:00 et 18:00 en 2021 et 2022, exécutez:
Exemple :
LOCALDB.ADMIN(ADMIN)=> select(select sum(PASSENGER_COUNT) from YELLOW_TAXI_JANUARY_2022_LOADED where TPEP_PICKUP_DATETIME::time > '1:00am' and TPEP_PICKUP_DATETIME::time < '6:00am') as "overnight passengers 2022", (select sum(PASSENGER_COUNT) from MYLAKE.TAXIDATA.YELLOW_TAXI_JANUARY_2021 where TPEP_PICKUP_DATETIME::time > '1:00am' and TPEP_PICKUP_DATETIME::time < '6:00am') as "overnight passengers 2021";Sortie :
overnight passengers 2022 | overnight passengers 2021 ---------------------------+--------------------------- 163058 | 33469 (1 row)