Création d'un fichier dans le HDFS
Pour créer un fichier dans le HDFS, vous pouvez utiliser l'interface en ligne de commande (CLI) Hadoop ou l'API Java HDFS. Dans cette section, nous allons montrer comment créer un fichier dans le HDFS en utilisant l'interface en ligne de commande Hadoop.
Prérequis
Avant de pouvoir créer un fichier dans le HDFS, vous devez avoir un cluster Hadoop en cours d'exécution et les autorisations nécessaires pour interagir avec le système de fichiers. Assurez-vous que l'interface en ligne de commande Hadoop est installée et configurée sur votre système.
Création d'un fichier dans le HDFS en utilisant l'interface en ligne de commande Hadoop
- Ouvrez un terminal sur votre système Ubuntu 22.04.
- Démarrez les services Hadoop en exécutant les commandes suivantes :
sudo service hadoop-namenode start
sudo service hadoop-datanode start
- Utilisez la commande
hdfs dfs
pour créer un fichier dans le HDFS. La syntaxe de base est :
hdfs dfs -put <local_file_path> <hdfs_file_path>
Ici, <local_file_path>
est le chemin du fichier sur votre système local, et <hdfs_file_path>
est le chemin où vous souhaitez créer le fichier dans le HDFS.
Par exemple, pour créer un fichier nommé example.txt
dans le répertoire /user/username/
du HDFS, exécutez la commande suivante :
hdfs dfs -put /path/to/local/example.txt /user/username/example.txt
- Vérifiez que le fichier a été créé dans le HDFS en exécutant la commande suivante :
hdfs dfs -ls /user/username/
Cela répertoriera les fichiers et les répertoires dans le répertoire /user/username/
, y compris le fichier example.txt
nouvellement créé.
Création d'un fichier dans le HDFS en utilisant l'API Java
Alternativement, vous pouvez créer un fichier dans le HDFS de manière programmée en utilisant l'API Java HDFS. Voici un extrait de code Java d'exemple :
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import java.io.IOException;
import java.net.URI;
public class CreateFileInHDFS {
public static void main(String[] args) throws IOException {
Configuration conf = new Configuration();
FileSystem fs = FileSystem.get(URI.create("hdfs://namenode:8020"), conf);
Path filePath = new Path("/user/username/example.txt");
fs.create(filePath).close();
System.out.println("File created in HDFS: " + filePath);
}
}
Dans cet exemple, nous créons un nouveau fichier nommé example.txt
dans le répertoire /user/username/
du cluster HDFS.