Генерация тестовых данных и нагрузочные K6 тесты для сервиса поиска

using Nest;
using System;
using System.Collections.Generic;
using System.Dynamic;

namespace ElasticApiClient
{
    public class NestClient
    {
        private readonly ElasticClient _api;
        public NestClient(string url, string user, string password)
        {
            var connectionSettings = new ConnectionSettings(new Uri(url));
            _api = new ElasticClient(connectionSettings);
            connectionSettings.BasicAuthentication(
                user,
                password);
        }

        public void DeleteUnusedIndices()
        {
            var response = _api.Indices.GetAsync(new GetIndexRequest(Indices.All)).GetAwaiter().GetResult();
            
            foreach (var index in response.Indices)
            {
                var indexName = index.Key;
                var countRequest = new CountRequest(Indices.Index(indexName));
                var numberOfDocuments = _api.CountAsync(countRequest).GetAwaiter().GetResult().Count;
                if (numberOfDocuments == 0)
                {
                    _api.Indices.DeleteAsync(indexName).GetAwaiter().GetResult();
                }
            }
        }

        public void CloneIndices(string sourceName, List<string> targetNames)
        {
            _api.Indices.UpdateSettingsAsync(Indices.Index(sourceName), u => u
                .IndexSettings(i => i
                    .Setting("index.blocks.write", true)
                )
            ).GetAwaiter().GetResult();

            foreach (var targetName in targetNames)
            {
                _api.Indices.CloneAsync(new CloneIndexRequest(sourceName, targetName)).GetAwaiter().GetResult();
            }

            _api.Indices.UpdateSettingsAsync(Indices.Index(sourceName), u => u
                .IndexSettings(i => i
                    .Setting("index.blocks.write", false)
                )
            ).GetAwaiter().GetResult();
        }

        public void DeleteTestIndices(List<string> testTenantIds)
        {
            var testIndexNames = new List<string>();
            foreach (var testTenantId in testTenantIds)
            {
                testIndexNames.Add($"{testTenantId}-documents");
            }
            
            var response = _api.Indices.GetAsync(new GetIndexRequest(Indices.All)).GetAwaiter().GetResult();
            
            foreach (var index in response.Indices)
            {
                var indexName = index.Key;
                if (testIndexNames.Contains(indexName.Name))
                {
                    _api.Indices.DeleteAsync(indexName).GetAwaiter().GetResult();
                }
            }
        }

        public void IndexMany(List<ExpandoObject> expandos, string indexName)
        {
            var ids = new List<Guid>();
            foreach (var expando in expandos)
            {
                var byName = (IDictionary<string, object>)expando;
                var documentId = (Guid)byName["documentId"];
                ids.Add(documentId);
            }

            var id = 0;
            _api.Bulk(bd => bd.IndexMany(expandos, (descriptor, s) => descriptor.Index(indexName).Id(ids[id++])));
        }
    }
}