Интеграция Cosmos DB с OData с помощью приложения функции запуска Azure Http - PullRequest
Новая
       70

Интеграция Cosmos DB с OData с помощью приложения функции запуска Azure Http

0 голосов
/ 29 января 2020

Цель: реализовать oData Azure Функция триггера Http, чтобы уменьшить задержку.

У меня 3,5 записи в cosmosdb и запрос данных, используя приложение azure Функция триггера Http.

Я запрашиваю данные CosmosDB через azure Клиент DocumentDB в azure Функция триггера Http. 

        public static async Task<IActionResult> MachinesByRegion_Get(
        [HttpTrigger(AuthorizationLevel.Function, "get", Route = "Region/Machines")]HttpRequest req,
        ILogger log)
    {

        log.LogInformation("GetMachinesByRegion function Started to process a request.");

        // check parameters
        if (string.IsNullOrEmpty(req.Query["PageSize"]) || string.IsNullOrEmpty(req.Query["PageNumber"]))
            return new BadRequestObjectResult(new PostActionResponse(400, "Please provide valid PageSize and PageNumber"));

        // Number of documents per page
        int pageSize = int.Parse(req.Query["PageSize"]);
        Dictionary<string,string> field = new Dictionary<string, string>();
        string columns = "*";
        if (!string.IsNullOrEmpty(req.Query["Fields"]))
        {
            string columnstring = req.Query["Fields"].ToString();
            field.Add("Fields", columnstring);
            string[] columnarr = columnstring.Split(',');
            int arraylength = columnarr.Length;

            // Build Selection columns
            if (arraylength != 0)
            {
                StringBuilder strinbuilder = new StringBuilder("c.id, ");
                int i = 1;
                foreach (string value in columnarr)
                {
                    strinbuilder.Append($"c.{value.Replace(" ", String.Empty)}");
                    if (arraylength > i)
                        strinbuilder.Append(", ");
                    i++;
                }
                columns = strinbuilder.ToString();
            }
        }

        // Parse Query Parameter
        int pagenumber = int.Parse(req.Query["PageNumber"]);

        int offset = pagenumber == 1 ? 0 : (pagenumber - 1) * pageSize;

        // Bulid query string based on request
        string sqlstr = string.Format($"SELECT {columns} FROM c ORDER BY c.id ASC OFFSET {offset} LIMIT {pageSize}");


        Helper.TraceLogWriter(log, "Summary:");
        Helper.TraceLogWriter(log, "--------------------------------------------------------------------- ");
        Helper.TraceLogWriter(log, $"Collection : {DBConstants.DataBaseName.Telemetry}.{DBConstants.ContainerName.KomatsuMachine}");
        Helper.TraceLogWriter(log, $"The Query String : {sqlstr}");
        Helper.TraceLogWriter(log, "--------------------------------------------------------------------- ");
        Helper.TraceLogWriter(log, "");

        try
        {
            // Feed Options 
            var options = new FeedOptions
            {
                MaxItemCount = pageSize,
                MaxDegreeOfParallelism = -1,
                EnableCrossPartitionQuery = true,
            };

            // Create CosmosDB Connection URI
            Uri collectionUri = UriFactory.CreateDocumentCollectionUri(databaseId: DBConstants.DataBaseName.Telemetry, collectionId: DBConstants.ContainerName.KomatsuMachine);

            ConnectionPolicy connPolicy = new ConnectionPolicy
            {
                ConnectionMode = ConnectionMode.Direct,
                ConnectionProtocol = Protocol.Tcp
            };

            using var client = new DocumentClient(new Uri(BaseRepository.EndpointUri), BaseRepository.PrimaryKey, connPolicy);
            // Get the List of Items against the Query string
            var results = client.CreateDocumentQuery(collectionUri, sqlstr, options).ToList();
            int records = results.Count;
            Helper.TraceLogWriter(log, $"Retrieved Documents: {records}");

            Helper.TraceLogWriter(log, $"Sample Document: {JsonConvert.DeserializeObject(JsonConvert.SerializeObject(results[0]))}");

            await Task.Yield();

            // Build base url                    
            var pages = new PageLinkBuilder($"{BaseRepository.BaseUrl}/api/Region/Machines", pagenumber, pageSize, records, field);

            return (ActionResult)new OkObjectResult(new PagedResult
            {
                PageNumber = pagenumber,
                PageSize = records,
                Pages = pages,
                Results = results
            });
        }
        catch (Exception ex)
        {
            Helper.TraceErrorWriter(log, $"Exception caught in GetMachinesByProduct: {ex.Message}");
            return new UnprocessableEntityObjectResult(new PostActionResponse(422, "Exception in CosmosDB, Please check logs"));
        }
    }

Я просто хочу включить oData для оптимизации c производительности в случае выбора, фильтрации и порядка и т. Д. c.

в cosmosDB, в документе много полей, если они включены, это уменьшит размер данных.

У меня был обзор.
Пожалуйста, нажмите здесь

Это для Web API. но мне нужно для azure Http триггер приложение приложение

...