sql >> Database teknologi >  >> RDS >> Mysql

Står over for et problem under konfiguration af MySql med apache-luftstrøm i Hadoop

Følg disse trin for at installere Apache Airflow med MySQL ved hjælp af Anaconda3

1) Installer forudsætninger

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

2) Installer Anaconda3 (leveres 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

Sørg for at du conda initialize når du bliver bedt om det under installationen. Dette vil sikre, at den korrekte version af python og pip bruges i de efterfølgende trin.

3) Installer Apache Airflow

pip install apache-airflow[mysql,celery]

Du kan tilføje andre underpakker efter behov. Jeg har kun inkluderet dem, der kræves for, at Airflow kan bruge MySQL-databasen som backend.

4) Initialiser luftstrøm

export AIRFLOW_HOME=~/airflow
airflow initdb

Herfra har jeg efterlignet de trin, du har fulgt for at konfigurere MySQL Server

5) Installer 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) Log ind på MySQL og konfigurer databasen til 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) Opdater Airflow-konfigurationsfil (~/airflow/airflow.cfg)

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

8) Initialiser luftstrøm

airflow initdb



  1. Transactionscope-undtagelse denne platform understøtter ikke distribuerede transaktioner, mens forbindelsesobjekt åbnes

  2. 3 måder at returnere alle tabeller UDEN en primær nøgle i SQL Server

  3. Sådan konfigureres PostgreSQL til at acceptere alle indgående forbindelser

  4. at vælge rækker, der er forekommet mere end tre gange