python - SQLAlchemy 从 JSON 列表插入到数据库

Question

我有一个包含 JSON 的列表，如下所示:

print(type(listed)) # <class 'list'>
print (listed)

[
   {
       "email": "x@gmail.com",
       "fullname": "xg gf",
       "points": 5,
       "image_url", "https://imgur.com/random.pmg"
   },
   {
        ... similar json for the next user and so on
   }
]

我正在尝试将它们插入到我的 postgres 数据库中，该数据库具有如下模型:

class Users(db.Model):
    __tablename__ = 'users'

    email = db.Column(db.String(), primary_key=True)
    displayName = db.Column(db.String())
    image = db.Column(db.String())
    points = db.Column(db.Integer())

但是我很困惑，我尝试了几种方法但没有任何效果，任何人都可以通过一个示例来指导我如何正确地做到这一点？

Answer 1

这是一个没有 pandas 的解决方案，使用 SQLAlchemy Core

创建引擎

engine = sqlalchemy.create_engine('...')

使用引擎作为绑定(bind)参数加载元数据

metadata = sqalchemy.Metadata(bind=engine)

引用表格

users_table = sqlalchemy.Table('users', metadata, autoload = True)

然后您就可以开始插入

for user in json:
    query = users_table.insert()
    query.values(**user)

    my_session = Session(engine)
    my_session.execute(query)
    my_session.close()

这会为每个用户创建一个 json session ，但我想你可能会喜欢它。它非常灵活，适用于任何 table ，您甚至不需要模型。只需确保 json 不包含数据库中不存在的任何列(这意味着您需要在 json 键和数据库列名称中使用“img_url”(列名称))