FlaskからRDSのMySQLに接続して、migrationしたいです

Question

実現したいこと

SQLAlchemyを利用してFlaskアプリのDBとしてRDS上のMySQLに接続したいです。

前提

SQLiteをDBとして利用してた際には、flask db migrateコマンドが実行できました。
MySQL Workbechやvscodeの拡張機能からは接続できました。

発生している問題・エラーメッセージ

sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError) (1045, "Access denied for user 'ユーザー名'@'自宅のIPアドレスのようなもの' (using password: YES)")
(Background on this error at: https://sqlalche.me/e/20/e3q8)

該当のソースコード

#app.py

from flask import Flask
from flask_login import LoginManager
from flask_migrate import Migrate
from flask_sqlalchemy import SQLAlchemy
from flask_wtf.csrf import CSRFProtect
from apps.config import config

db = SQLAlchemy()
csrf = CSRFProtect()
login_manager = LoginManager()
login_manager.login_view = "auth.signup"
login_manager.login_message = ""

def create_app(config_key):
    app = Flask(__name__)
    app.config.from_object(config[config_key])
    
    csrf.init_app(app)
    
    db.init_app(app)
    Migrate(app, db)
    login_manager.init_app(app)
    
    from apps.crud import views as crud_views#この場所でのimportじゃないと上手くいかない
    from apps.auth import views as auth_views#関数内でのimportじゃないと上手くいかない？
    from apps.scrapy import views as sc_views
    
    app.register_blueprint(crud_views.crud, url_prefix="/crud")
    app.register_blueprint(auth_views.auth, url_prefix="/auth")
    app.register_blueprint(sc_views.sc)
    return app

#config.py

from pathlib import Path
import secrets

basedir = Path(__file__).parent.parent

class BaseConfig:
    SECRET_KEY = secrets.token_urlsafe(32)
    WTF_CSRF_SECRET_KEY = secrets.token_urlsafe(40)


class LocalConfig(BaseConfig):
    SQLALCHEMY_DATABASE_URI = 'mysql+pymysql://ユーザー名:パスワード@エンドポイント:3306/DB名'
    SQLALCHEMY_TRACK_MODIFICATIONS = False
    SQLALCHEMY_ECHO=True


class TestingConfig(BaseConfig):
    SQLALCHEMY_DATABASE_URI = 'mysql+pymysql://ユーザー名:パスワード@エンドポイント:3306/DB名'
    SQLALCHEMY_TRACK_MODIFICATIONS = False
    WTF_CSRF_ENABLED = False

config = {
    "testing": TestingConfig,
    "local": LocalConfig
}

試したこと

下記コードを実行することでMySQL上にDBを作製することができました。

#create_db.py
import mysql.connector

mydb = mysql.connector.connect(
    host = RDSのエンドポイント,
    user = ユーザー名,
    password = パスワード,
)

my_cursor = mydb.cursor()

my_cursor.execute("CREATE DATABASE flask_db")

my_cursor.execute("SHOW DATABASES")
for db in my_cursor:
    print(db)

また、エラー文に記載されていたサイトの記述を読んでみた結果、SQLAlchemyのDBAPIがエラーの原因ぽいです。

 https://sqlalche.me/e/20/e3q8

補足情報（FW/ツールのバージョンなど）

よろしくお願いいたします。

Answer 1

エラーメッセージだけを見ると、認証エラーですが、認証エラー以外の時にも似たようなものが出た気がするので、以下を確認すると良いと思います。

1. ユーザID/PASSWORDはあっているか？
2. ユーザIDは、対象のDBを操作する権限を持っているか？
3. localhostで接続していない場合、外部からの接続を許可しているか？
4. rootでアクセスしていないか？
   mysqlかmariadbか忘れましたが、セキュリティの関係でrootだと上手くアクセスできなかったような？

Comments

[ko-ske]

ご回答ありがとうございます。
現時点で、確認できたことを以下に記載いたします。
1.ユーザID/PASSWORDはあっているか？
　→RDS上でMySQL作成時のものを利用しております。また、MySQL Workbench経由では接続できるため
　　問題ないと考えております。

2.ユーザIDは、対象のDBを操作する権限を持っているか？
　→EC2経由でMySQLに接続し、（show grants for 'ユーザー名'@'ホスト名'）というコマンドで確認した結果、
　全権限を持っていると思われる結果が得られました。

3.localhostで接続していない場合、外部からの接続を許可しているか？
　→作業場所にあわせて、MySQLに対するインバウンドルール変更しているので、大丈夫だと考えております。

4.rootでアクセスしていないか？
　→RDSのMySQL作製時に登録したマスターユーザー名を使用しているため大丈夫だと考えております。

上記の確認事項を含め、勘違いや見落としがあると思うのでおかしな点があればご指摘ください。
お時間を割いていただきありがとうございます。

[FiroProchainezo]

RDSという単語を見落としてました・・・

以下に「SQLAlchemy+MySQL+AmazonRDSでDBを作ってみた」という記事があったので、上から確認してみてはいかがでしょうか？
https://zenn.dev/megane_otoko/articles/061_make_db_mysql_sqlalchemy

Flask-SQLAlchemyはSQLAlchemyのラッパーなので、若干読み替えが必要と思いますが、接続部分は参考になると思います。