neon-upsert.py

import dotenv

dotenv.load_dotenv()

NEON_CONNSTRG = os.getenv("NEON_CONNSTRG")

import sqlalchemy
from sqlalchemy import create_engine
from sqlalchemy import text

neon_eng = create_engine(NEON_CONNSTRG)

neon_conn = neon_eng.connect()

neon_conn.execute(
                text(
                "INSERT INTO nix_tweets_two (id, tweetid, tweettext, userurl) VALUES (:id, :tweetid, :tweettext, :userurl) ON CONFLICT (tweetid) DO NOTHING"
                ),
                [{"id":nix_tweets_uuid, "tweetid": int(tweet_id), "tweettext": tweet_text, "userurl": user_url}]
                )
neon_conn.commit()

created gist