C#中的Kafka交易范围
试图在MongoDB中持续一些数据,并将几条消息发布到交易中的所有内容。我正在考虑使用dotnet transactionscope,但我看不到如何将其应用于Confluent Ka…
如何在交易中正确执行和回滚多个步骤,包括数据库写,blob上传和异步消息传递?
我必须在一次交易中执行以下三个步骤。 通过EF核心 将文档上传到Azure Blob容器 中,通过Azure Service Bus队列将文档上传 到Azure Blob容器中,我正…
EF Core-他的SqlTransaction已经完成;它不再可用。在 Microsoft.Data.SqlClient.SqlTransaction.ZombieCheck()
我们在应用程序中使用具有存储库模式的 EF Core。 但是我们随时都会随机遇到一个问题,但是问题的频率不是很高,但在 300 到 400 个请求之后仍然会随…
使用 ServiceBusMessageBatch 和在 TransactionScope 中发送多条消息有什么区别?
使用Azure.Messaging.ServiceBus。 我想在一个事务中向 Azure 服务总线发送多条消息。我同意每笔交易 100 条消息的限制。 这两种方法的优缺点是什么?…
带 TransactionScope 的 Rebus 处理程序
我已经设置了一个 Rebus 处理程序,并将事务范围附加到 MSMQ 和 RabbitMQ。处理程序 100% 处理前几条消息。几分钟后,当我尝试向队列发布新消息时,我…
Castle Active Record NHibernate Same Session 同一对象的2个版本
我在数据库中有一辆汽车,其中模型字段是“法拉利”, using (new TransactionScope()) { var car = Find(1); car.Model = "Ferrari Plus"; // i need…
TransactionScope 是否可以与预先存在的连接一起使用?
我有这样的代码: try { using (TransactionScope scope = new TransactionScope()) { some_db_function(); for (i = 0; i < 10; i++) { some_other_d…
如何获取 EF Code First DbContext 事务行标识?
是否可以在 SaveChanges 方法之后但在使用 DbContext 调用 TransactionScope.Complete 之前获取记录的标识?我们是否需要转换为 ObjectContext 才能获…
“脏读”在设置为未提交隔离级别的事务范围内不工作
我有一个类似这样的代码: using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required), new TransactionOptions) { Is…
C# - TransactionScope - TransactionAbortedException - 事务已中止
我有这样的代码: class Importer { private DatabaseContext m_context; public: Importer() { m_context = new DatabaseContext(); m_context.Comma…