我正在尝试了解监控应用程序的最佳建模。

我有一个监控应用程序，它将每 30 分钟运行一次，以从目标系统获取统计信息并将详细信息存储在 MongoDB 中。

用例:

产品、公司

将有大约 2000 种产品。产品会增加/减少，但每个月的增长不会超过10%。所以，我预计 future 1 年不会超过 3000。

公司是每种产品的消费者。每个产品将有 1 到 10 个公司在使用该产品。消费者数量也会上下波动。

因此，在每次运行中，我们都会获得产品列表以及相应的公司。产品详细信息将是这样的，

产品:

1. 产品名称
2. 总人数(这将给出当前可用的人数，并且会在每次投票时发生变化)
3. 产品重量
4. 耐用天数(可能会不时更改)
5. 公司列表 - 谁在使用该产品

产品示例数据:

{
            "productName" : "Small Box",
            "total" : NumberLong(1000),
            "weight" : "1.5",
            "durability" : "20",
            "companies" : [
                {
                    "name" : "Nike",
                    "taken" : NumberLong(10)
                },
                {
                    "name" : "Reebok",
                    "taken" : NumberLong(20)
                }
            ]
}

在这里，每个民意测验的计数都会不断变化。

网络应用:

将有 3 个屏幕显示详细信息。

1. 仪表板 - 将显示高级统计数据，例如(产品数量、公司数量、总规模......)

2. 产品 - ListView (查看完整列表)- 将在选择任何产品时显示产品的详细信息

   在这里，我将必须显示产品详细信息，并且必须列出所有消费的公司。

3. 公司 - ListView (查看完整列表)- 将显示每个选择任何公司的详细信息

   在这里，我必须显示公司详细信息及其消费的所有产品。

顺便说一句，我目前正在存储。

1. 仪表板集合 - 显示统计详细信息，例如产品总数、公司总数......

   { “时间” : “总产品”:NumberLong(1000)， “总公司”:“1.5”，

2. 产品集合 - 将包含以下详细信息。

{
                "productName" : "Small Box",
                "total" : NumberLong(1000),
                "weight" : "1.5",
                "durability" : "20",
                "companies" : [
                    {
                        "name" : "Nike",
                        "taken" : NumberLong(10)
                    },
                    {
                        "name" : "Reebok",
                        "taken" : NumberLong(20)
                    }
                ]
    }

1. 公司集合 - 将包含以下详细信息

{
            "companyName" : "Nike",
            "products" : [
                {
                    "name" : "Small Box",
                    "taken" : NumberLong(10)
                },
                {
                    "name" : "Medium Box",
                    "taken" : NumberLong(20)
                }
            ] 
}

因此，在每次运行时，我都会生成唯一的 ID，并将此 ID 添加到所有存储的数据中。我在这些集合中只保留了最近 2 周的数据。超过 2 周的数据将每天清理。

因此，当用户来到仪表板时，进行排序以获取最新记录并显示详细信息。 Dashboard 集合中每次运行只会有一条记录，并且会有最近 2 周的记录。

当用户来到产品屏幕时，仍然必须从仪表板获取最新记录以获取 UniqueId 并转到产品集合以获取该 UniqueId 的所有记录，因为每次运行将有大约 2000 条记录。公司集合也是如此。

在这里，我必须始终显示最新数据。当用户转到产品或公司屏幕时，我将转到 2 个不同的集合。

有没有更好的方法？

最佳答案

请查看它对您如何准备schema有帮助 注意:Mongo 版本:3.6.5

产品收藏

/* 1 */
{
    "_id" : ObjectId("5bb1e270269004e06093e178"),
    "productName" : "Small Box",
    "total" : NumberLong(1000),
    "weight" : "1.5",
    "durability" : "20",
    "companies" : [ 
        ObjectId("5bb1e2d2269004e06093e17b"), 
        ObjectId("5bb1e2d8269004e06093e17c")
    ],
    "date" : ISODate("2018-10-01T09:28:40.502Z")
}

/* 2 */
{
    "_id" : ObjectId("5bb1e293269004e06093e179"),
    "productName" : "Large Box",
    "total" : 1000.0,
    "weight" : "1.2",
    "durability" : "20",
    "companies" : [ 
        ObjectId("5bb1e2d8269004e06093e17c"), 
        ObjectId("5bb1e2de269004e06093e17d")
    ],
    "date" : ISODate("2018-10-01T09:28:40.502Z")
}

/* 3 */
{
    "_id" : ObjectId("5bb1e29d269004e06093e17a"),
    "productName" : "Medium Box",
    "total" : 1000.0,
    "weight" : "1.2",
    "durability" : "20",
    "companies" : [ 
        ObjectId("5bb1e2d2269004e06093e17b"), 
        ObjectId("5bb1e2d8269004e06093e17c"), 
        ObjectId("5bb1e2de269004e06093e17d")
    ],
    "date" : ISODate("2018-07-01T09:28:40.502Z")
}

公司合集

/* 1 */
{
    "_id" : ObjectId("5bb1e2d2269004e06093e17b"),
    "companyName" : "Nike"
}

/* 2 */
{
    "_id" : ObjectId("5bb1e2d8269004e06093e17c"),
    "companyName" : "Reebok"
}

/* 3 */
{
    "_id" : ObjectId("5bb1e2de269004e06093e17d"),
    "companyName" : "PUMA"
}

通过公司获取单品

db.getCollection('products').aggregate([{
      $match :  { "_id" : ObjectId("5bb1e270269004e06093e178") } },
       { $lookup : {
           from : 'company',
           foreignField : '_id',
           localField : 'companies',
           as : 'companies'
           }
       }
      ])

所有带有公司列表的产品

db.getCollection('products').aggregate([
       { $lookup : {
           from : 'company',
           foreignField : '_id',
           localField : 'companies',
           as : 'companies'
           }
       }
      ])

按 id 分类的公司及其使用的产品

  db.getCollection('company').aggregate([{
          $match :  { "_id" : ObjectId("5bb1e2d2269004e06093e17b") } },
           { $lookup : {
               from : 'products',
               foreignField : 'companies',
               localField : '_id',
               as : 'products'
               }
           }
          ])

还可以通过在每个产品中添加日期字段来获取上周数据

    db.getCollection('products').aggregate([{
          $match :  { 
              date: {
                $gte: new Date(new Date() - 7 * 60 * 60 * 24 * 1000)
        } } },
           { $lookup : {
               from : 'products',
               foreignField : 'companies',
               localField : '_id',
               as : 'products'
               }
           }
    ])

获取公司最新产品

db.getCollection('products').aggregate([
       { $sort : { date : -1} },
       { $limit : 1},
       { $lookup : {
           from : 'company',
           foreignField : '_id',
           localField : 'companies',
           as : 'companies'
           }
       }
      ])

关于mongodb - 用于监控应用程序的 Mongo 数据建模，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/52486909/