Interrogez les données stockées dans OSS-HDFS en exécutant Trino sur un cluster EMR.
Prérequis
Un cluster EMR (version EMR-3.42.0 ou ultérieure, ou version EMR-5.8.0 ou ultérieure) avec Trino sélectionné. Créer un cluster.
Le service OSS-HDFS est activé et l'accès est autorisé. Activer le service OSS-HDFS.
Procédure
-
Interrogez les données du service OSS-HDFS.
-
Connectez-vous à l'interface CLI de Trino.
Dans la console EMR on ECS, accédez à l'onglet Services > Trino > Configure pour obtenir l'adresse <Trino_server_address> et le port <Trino_server_port> du serveur Trino.
trino --server <Trino_server_address>:<Trino_server_port> --catalog hive -
Créez un schéma pour OSS.
create schema testDB with (location='oss://{yourBucketName}.{yourBucketEndpoint}/{schema_dir}'); -
Utilisez le schéma.
use testDB; -
Créez une table.
create table tbl (key int, val int); -
Insérez des données dans la table.
insert into tbl values (1,666); -
Interrogez les données de la table.
select * from tbl;
-