如何通过Azure Gremlin查询验证文档存在并实现不存在则插入（附C#函数）

我明白你现在的困惑——看起来简单的"检查存在再插入"操作，在Gremlin API里得注意原子性和查询逻辑的正确性。下面我会基于你给出的代码片段，帮你完成完整的实现，同时避开一些常见的坑。

核心思路 #

• 先通过Gremlin查询，基于业务唯一标识（比如AuditId）判断目标文档是否存在
• 如果查询无结果，执行插入操作
• 高并发场景下要处理竞态冲突，避免重复插入

完整实现代码 #

using System;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.Azure.Documents;
using Microsoft.Azure.Documents.Client;
using Newtonsoft.Json.Linq;

public static async Task StoreAuditDetail(AuditDetailResponse auditDetail, string endpointUrl, string authorizationKey)
{
    // 初始化Cosmos Client
    using (var cosmosClient = new DocumentClient(new Uri(endpointUrl), authorizationKey))
    {
        const string db = "iauditor-database";
        const string collection = "audit-details";
        Uri databaseUri = UriFactory.CreateDatabaseUri(db);
        Uri collectionUri = UriFactory.CreateDocumentCollectionUri(db, collection);

        // 1. 验证文档是否存在（这里假设AuditId是业务唯一标识）
        var existenceQuery = $"g.V().has('AuditId', '{auditDetail.AuditId}')";
        var queryResultSet = await cosmosClient.ExecuteGremlinQueryAsync<JObject>(collectionUri, existenceQuery);

        if (!queryResultSet.Any())
        {
            // 2. 文档不存在，执行插入
            try
            {
                // 构造符合Gremlin顶点格式的文档
                var auditDocument = JObject.FromObject(new
                {
                    id = Guid.NewGuid().ToString(), // Cosmos DB要求的主键id
                    AuditId = auditDetail.AuditId,
                    AuditDate = auditDetail.AuditDate,
                    Status = auditDetail.Status,
                    label = "AuditDetail" // 可选但推荐的顶点类型标签
                    // 按需添加其他业务字段
                });

                await cosmosClient.CreateDocumentAsync(collectionUri, auditDocument);
                Console.WriteLine($"审计详情 {auditDetail.AuditId} 已成功插入");
            }
            catch (DocumentClientException ex)
            {
                // 处理并发插入冲突：如果其他进程已经插入了同一条数据
                if (ex.StatusCode == System.Net.HttpStatusCode.Conflict)
                {
                    Console.WriteLine($"审计详情 {auditDetail.AuditId} 已被其他进程插入，跳过本次操作");
                }
                else
                {
                    throw; // 抛出其他未知异常
                }
            }
        }
        else
        {
            Console.WriteLine($"审计详情 {auditDetail.AuditId} 已存在，跳过插入");
        }
    }
}

// 假设的业务模型类，根据你的实际结构调整
public class AuditDetailResponse
{
    public string AuditId { get; set; }
    public DateTime AuditDate { get; set; }
    public string Status { get; set; }
    // 其他业务属性...
}

关键细节说明 #

• 唯一标识选择：我用AuditId作为判断依据，你可以换成你的业务主键（比如订单号、流水号）
• 索引优化：一定要给AuditId字段创建顶点属性索引，否则Gremlin查询会全表扫描，性能极差。你可以在Cosmos DB门户的集合索引设置里配置
• 并发处理：即使先查后插，高并发下还是可能出现两个进程同时通过检查、重复插入的情况，所以捕获409冲突异常是必要的
• 进阶UPSERT方案：如果你的场景允许"存在则更新，不存在则插入"，可以用Gremlin的mergeV步骤实现原子操作，避免竞态问题：

  var upsertQuery = $"g.mergeV(['AuditId','{auditDetail.AuditId}'])" +
                    $".property('AuditDate', '{auditDetail.AuditDate}')" +
                    $".property('Status', '{auditDetail.Status}')" +
                    $".property('label', 'AuditDetail')";
  await cosmosClient.ExecuteGremlinQueryAsync<JObject>(collectionUri, upsertQuery);
  

内容的提问来源于stack exchange，提问作者invernomuto