edward_ryan
04/17/2024, 9:57 AMEdgar Ramírez (Arch.dev)
04/17/2024, 3:40 PMvisch
04/17/2024, 3:52 PMedward_ryan
04/17/2024, 3:55 PMsqlalchemy_url = URL.create(
drivername="mysql+pymysql",
username=config["user"],
password=config["password"],
host=config["host"],
port=config["port"],
database=config["database"],
query=config.get("sqlalchemy_options"), # type: ignore[arg-type])
But this isn’t code we should be updating?
Here is my redacted config if it helps:
name: target-mysql
variant: thkwag
pip_url: thk-target-mysql
config:
sqlalchemy_url: <mysql+pymysql://meltano_user:<your_password>@34.69.22.60:3306/meltano_the_daily_upside?ssl_ca=/home/meltano/meltano-the-daily-upside/tdu-meltano/.secrets/server-ca.pem&ssl_cert=/home/meltano/meltano-the-daily-upside/tdu-meltano/.secrets/client-cert.pem&ssl_key=/home/meltano/meltano-the-daily-upside/tdu-meltano/.secrets/client-key.pem>
edward_ryan
04/17/2024, 4:07 PMEdgar Ramírez (Arch.dev)
04/17/2024, 4:14 PMtarget-mysql
installed and run something like
import sqlalchemy as sa
URL = "<mysql+pymysql://meltano_user>:<your_password>@34.69.22.60:3306/meltano_the_daily_upside?ssl_ca=/home/meltano/meltano-the-daily-upside/tdu-meltano/.secrets/server-ca.pem&ssl_cert=/home/meltano/meltano-the-daily-upside/tdu-meltano/.secrets/client-cert.pem&ssl_key=/home/meltano/meltano-the-daily-upside/tdu-meltano/.secrets/client-key.pem"
engine = sa.create_engine(URL)
with engine.connect() as conn:
conn.execute("SELECT 1")
edward_ryan
04/17/2024, 4:26 PMedward_ryan
04/17/2024, 4:56 PMedward_ryan
04/17/2024, 5:04 PMedward_ryan
04/17/2024, 5:04 PMEdgar Ramírez (Arch.dev)
04/17/2024, 5:04 PMpymysql
driver from it:
https://github.com/thkwag/target-mysql/blob/c84fe01850b0470d39e4d0c56fd884e2019174c4/target_mysql/sinks.py#L56-L63edward_ryan
04/17/2024, 5:05 PMEdgar Ramírez (Arch.dev)
04/17/2024, 5:06 PMMindaugas Nižauskas
04/25/2024, 10:06 AMssl=True
or ssl_mode='REQUIRED'
somewhere in this class? I see that here we can pass it to Connection, but not sure if I am not mixing something