Mysql
 sql >> Teknologi Basis Data >  >> RDS >> Mysql

Menghadapi masalah saat mengonfigurasi MySql dengan aliran udara Apache di Hadoop

Ikuti langkah-langkah ini untuk menginstal Apache Airflow dengan MySQL menggunakan Anaconda3

1) Instal Prasyarat

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

2) Instal Anaconda3 (dilengkapi dengan 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

Pastikan Anda melakukan conda initialize ketika diminta selama instalasi. Ini akan memastikan versi python dan pip yang benar digunakan pada langkah selanjutnya.

3) Instal Apache Airflow

pip install apache-airflow[mysql,celery]

Anda dapat menambahkan subpaket lain sesuai kebutuhan. Saya hanya menyertakan yang diperlukan Airflow untuk menggunakan database MySQL sebagai backend.

4) Inisialisasi Aliran Udara

export AIRFLOW_HOME=~/airflow
airflow initdb

Dari sini, saya telah meniru langkah-langkah yang Anda ikuti untuk mengkonfigurasi Server MySQL

5) Instal Server MySQL

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) Masuk ke MySQL dan konfigurasikan database untuk 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) Perbarui file konfigurasi Aliran Udara (~/airflow/airflow.cfg)

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

8) Inisialisasi Aliran Udara

airflow initdb



  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Apakah saya harus menggunakan mysql_real_escape_string jika saya mengikat parameter?

  2. Adakah yang bisa menjelaskan fitur Pengindeksan Magentos secara detail?

  3. Kutipan tunggal, Kutipan ganda, dan Backtick di MySQL

  4. hapus baris dari beberapa tabel

  5. Query Mysql dengan variabel mysql tidak berfungsi di Zend Framework 1