On a deux option après avoir dézipper le répertoire nifi
1 er option
aller dans cd nifi-1.9.0 après dans bin puis :
sudo ./[Link] start
après aller dans
[Link]
2eme option
configurer nifi : le host name et le port
sudo mv nifi-1.9.0-bin /usr/local/nifi
entrer dans nifi puis taper
sudo chmod 777 -R nifi-1.9.0
ou
sudo chown -R $USER:$USER nifi-1.9.0
aller dans /nifi-1.9.0/conf$
taper
gedit [Link]
mettre [Link]=9999 au lieu de 8080
apres on va mettre le ip adresse de notre machine dans [Link]
on tape
ifconfig
on cherche inet addr: [Link]
[Link]=[Link]
[Link]=9999
aller dans /nifi-1.9.0/bin$ et taper
./[Link] start
TRANSFER un fichier du systeme au hdfs
d’abord démarrer service hadoop
aller sur le web de nifi
ajouter deux process getfile et putHDFS
dans getfile
on indique le dossier qui contient les fichiers à copier dans propriétés dans directory
relier le avec puthdfs
dans puthdfs
on configure le chemin de fichiers suivants [Link], [Link] dans configure
processor dans l onglet proprieties dans hadoop configuration ressource
/home/ghazouani/Desktop/Hadoop/hadoop-2.7.3/etc/hadoop/hdfs-
[Link],/home/ghazouani/Desktop/Hadoop/hadoop-2.7.3/etc/hadoop/[Link]
donner le répertoire où on va copier le fichier dans configure processor dans l’onglet
proprieties dans directory hdfs://localhost:9000/cdac
hdfs dfs -ls / pour voir les répertoires qui existent dans votre hdfs
define succes relation ship
define failure relation ship
maintenat listenhttp
ajouter listenhttp processor et putfile processor
dans le processor listenhttp mettre 8282 dans listningport dans configure processor dans
l’onglet proprieties
dans putfile indiquer le rep où on va copier le fichier
on va aller dans shell commande et on va poster data sur notre pc à travers le port 8282
avant de taper cette commande il faut démarrer le processor listenHTTP
curl -X POST --data "test de curl pour poster les données"
[Link]
[Link]
pour voir le data
cliquer sur list queue
cliquer sur view
on va poster des donner par un programme python
créer un fichier [Link]
et y mettez
import requests
data = 'test python pour poster les donnees'
response = [Link]('[Link]
print (response)
pour l exécuter on tape
python3 [Link]