如何在Windows应用程序中异步调用Elasticsearch嵌套中的BulkAll方法

var settings = new ConnectionSettings(new Uri("http://localhost:9200"));
var client = new ElasticClient(settings);

var documents = new List<MyDocument>
{
    new MyDocument { Id = 1, Name = "Document 1" },
    new MyDocument { Id = 2, Name = "Document 2" },
    // 添加更多文档...
};

var bulkAllObservable = client.BulkAll(documents, b => b
    .Index("my_index")
    .BackOffRetries(2)
    .BackOffTime("30s")
    .RefreshOnCompleted()
    .Size(1000)
);

bulkAllObservable.Wait(TimeSpan.FromMinutes(15), next =>
{
    // 处理每个批次的结果
    if (next.IsValid)
    {
        Console.WriteLine($"Indexed {next.Items.Count} documents");
    }
    else
    {
        Console.WriteLine($"Error: {next.Error}");
    }
});

if (!bulkAllObservable.IsCompletedSuccessfully)
{
    Console.WriteLine("BulkAll operation did not complete successfully");
}