sql >> Databasteknik >  >> RDS >> Mysql

Står inför problem när du konfigurerar MySql med apache-luftflöde i Hadoop

Följ dessa steg för att installera Apache Airflow med MySQL med Anaconda3

1) Installationsförutsättningar

yum install gcc gcc-c++ -y
yum install libffi-devel mariadb-devel cyrus-sasl-devel -y
dnf install redhat-rpm-config

2) Installera Anaconda3 (levereras med Python 3.7.6)

yum install libXcomposite libXcursor libXi libXtst libXrandr alsa-lib mesa-libEGL libXdamage mesa-libGL libXScrnSaver
wget https://repo.anaconda.com/archive/Anaconda3-2020.02-Linux-x86_64.sh
chmod +x Anaconda3-2020.02-Linux-x86_64.sh 
./Anaconda3-2020.02-Linux-x86_64.sh

Se till att du gör conda initialize när du uppmanas under installationen. Detta kommer att se till att rätt version av python och pip används i de efterföljande stegen.

3) Installera Apache Airflow

pip install apache-airflow[mysql,celery]

Du kan lägga till andra underpaket efter behov. Jag har bara inkluderat de som krävs för att Airflow ska kunna använda MySQL-databas som backend.

4) Initiera luftflödet

export AIRFLOW_HOME=~/airflow
airflow initdb

Härifrån har jag härmat stegen du har följt för att konfigurera MySQL Server

5) Installera MySQL Server

rpm -Uvh https://repo.mysql.com/mysql80-community-release-el7-3.noarch.rpm 
sed -i 's/enabled=1/enabled=0/' /etc/yum.repos.d/mysql-community.repo 
yum --enablerepo=mysql80-community install mysql-server 
systemctl start mysqld.service

6) Logga in på MySQL och konfigurera databas för Airflow

mysql> CREATE DATABASE airflow CHARACTER SET utf8 COLLATE utf8_unicode_ci; 
mysql> CREATE user 'airflow'@'localhost' identified by 'Airflow123'; 
mysql> GRANT ALL privileges on *.* to 'airflow'@'localhost'; 

7) Uppdatera Airflow-konfigurationsfilen (~/airflow/airflow.cfg)

sql_alchemy_conn = mysql://airflow:[email protected]:3306/airflow
executor = CeleryExecutor

8) Initiera luftflödet

airflow initdb



  1. hur man jämför datum och tid i php/mysql

  2. MySQL-uppdatering tar (för) lång tid

  3. Ett frågesportobjekt per sida (php/mysql frågesportprogram)

  4. primära index kontra sekundära index:prestationsskillnader