先贴代码:
try:
# 判断表中数据是否存在,存在更新,不存在新增
if not existing:
db.session.execute(
ServiceAsset.__table__.insert(),
[{'xxx': xxx}]
)
else:
ServiceAsset.query.filter_by(host_id=xxx, port=xxx).update({'xxx':'xxx'})
db.session.commit()
except Exception as e:
db.session.rollback()
# ServiceAsset 表数据入库后,马上在 ServiceAsset 表进行一个查询获取 ServiceAsset 表的 id
try:
service_asset_query = ServiceAsset.query.filter(and_(xx=xx, xxx=xxx)).all()
if not service_asset_query:
log.write('info', None, 0, u'在 ServiceAsset 中根据 xx 和 xxx 未获取到资产信息')
pass
for saq in service_asset_query:
service_id_cur = saq.service_id
except Exception as e:
db.session.rollback()
大概插入了几百条数据,其中会有几条获取不到 service_asset_query。

请问下各位表哥们,有遇到这种情况吗?该如何解决