SqlAlchemy postgres bulk upsert

sample.py

from sqlalchemy.dialects import postgresql

def bulk_upsert(session: Session, 
                items: Sequence[Mapping[str, Any]]):
  session.execute(
    postgresql.insert(MyModel.__table__)
    .values(items)
    .on_conflict_do_update(
      index_elements=[MyModel.id],
      set_={MyModel.my_field.name: 'new_value'},
    )
  )