SQLAlchemy - 唯一记录插入

Question

我有一个可用的 API，它具有将记录插入数据库的功能。问题是，它在顶部插入任何记录，而不检查重复项/记录是否已存在。

进行该堵塞的最高效的方法是什么？

我正在使用 SQLAlchemy，因为这是我公司的标准（尤其是我们在 gcp 上工作），但我对该库不太熟悉，并且搜索我找不到任何有用的东西。

我当前的代码是：

def db_push(insert: dict)->dict:
    def insert_results(results):
        rows = []
        for i in results:
            rows.append(
                {
                    "name": i["Name"],
                    "id": i["id"],
                    "amount": I["amount"],
                    "invoice" : I["invoice"],
                    "country" : i["Country"]
                }
            )
        return rows

    insert = insert_results(insert)
    conn = engine.connect()
    m = MetaData()
    m.reflect(engine)
    customers = m.tables["customers"]
    _ = conn.execute(customers .insert(), insert)
    conn.close()

其中 get_engine 只是使用用户/密码等配置创建一个引擎实例（ sqlalchemy.engine.Engine ）。

感谢任何帮助！