将带有jsonb_each的Postgresql查询转换为sqlalchemy

from sqlalchemy import create_engine, Column, Integer, String, func
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

# 创建数据库连接
engine = create_engine('postgresql://username:password@localhost:5432/database')
Session = sessionmaker(bind=engine)
session = Session()

# 创建映射模型
Base = declarative_base()

class MyModel(Base):
    __tablename__ = 'my_table'
    id = Column(Integer, primary_key=True)
    data = Column(String)

# 查询并转换为sqlalchemy语法
query = session.query(MyModel.id, func.jsonb_each(MyModel.data).label('key_value'))
result = query.all()

# 打印结果
for row in result:
    print(row.id, row.key_value.key, row.key_value.value)