क्या एज़ूर कॉसमॉस डीबी - मोंगो एपीआई समर्थन एकत्रीकरण

Question

मैं document-centric design में निर्धारित समय श्रृंखला डेटा स्टोर करने के लिए cosmosdb का उपयोग करने के लिए देख रहा था। आधिकारिक mongodb चालक का उपयोग करके मैंने कुछ सरल एकत्रीकरण बयान लिखने की कोशिश की; हालांकि, मुझे यह त्रुटियां मिलीं कि $ अनचाहे और $ समूह समर्थित नहीं थे। यह देखते हुए कि cosmosdb को mongodb के ड्रॉप-इन प्रतिस्थापन के रूप में बताया गया था, क्या मुझे एक चरण याद आया या एकत्रीकरण एक समर्थित सुविधा नहीं है।

retrieve.Aggregate().Unwind(i => i.Observations).Group(new BsonDocument { 
     {"_id", "$Observations.Success"}, 
     {"avg", new BsonDocument{ 
     {"$avg", "$Observations.Duration"} 
     }} 
    }).ToList(); 

Answer 1

नवंबर 2017 की स्थिति के अनुसार ब्रह्मांड डीबी के MongoDB एपीआई अब, एकत्रीकरण पाइप लाइन का समर्थन करता है पाइपलाइन चरणों अपने मूल में पहचान के सभी सहित प्रश्न ($unwind, $group)।

समर्थित सुविधाओं के विशिष्टता here सूचीबद्ध हैं।

Answer 2

@neillunn से टिप्पणी और है कि प्रभावित लगता है कि cosmosdb के लिए एकत्रीकरण कार्यों मोंगो एपीआई के माध्यम से समर्थित नहीं हैं किसी भी दस्तावेज की कमी को देखते हुए। ऐसा लगता है कि intention कुल योग के लिए cosmosdb documentdb API SQL वाक्यविन्यास का उपयोग करना है।

LINQ सिंटेक्स

var client = new DocumentClient(new Uri("https://<account>.documents.azure.com"),<password>); 

    // issue query 
    var documentUri = UriFactory.CreateDocumentCollectionUri("Prod", "retrieve"); 
    var date = "20161011".Dump("Date"); 


    var max = client.CreateDocumentQuery<ObservationDocument>(documentUri) 
      .Where(i => i.Id == date) 
      .SelectMany(i => i.observations) 
      .Max(i => i.Duration); 

SQL सिंटैक्स

// explicit query 
var spec = new SqlQuerySpec("select value count(o.duration) from days d join o in d.observations where d._id = @id"); 
spec.Parameters = new Microsoft.Azure.Documents.SqlParameterCollection(); 
spec.Parameters.Add(new Microsoft.Azure.Documents.SqlParameter("@id", "20161010")); 
client.CreateDocumentQuery(UriFactory.CreateDocumentCollectionUri("Prod", "retrieve"), spec).Dump("As query");