如何限制数量。在水壶中使用的 mongodb 输入转换中检索到的行数。
我在 mongodb 输入查询中尝试了以下查询,但它们都不起作用:
{"$query" : {"$limit" : 10}} 或 {"$limit" : 10}
请让我知道我哪里出错了。
谢谢, 迪普蒂
您可以使用多种查询修改运算符。它们的名称并不完全直观,并且与您在 Mongo shell 中使用的函数名称不匹配,但它们的作用相同。
在您的情况下,您需要$maxScan
操作员。您可以将查询编写为:
{"$query": {...}, "$maxScan": 10}
我们必须使用 MongoDB 提供的聚合方法,这里是链接:docs.mongodb.org/manual/applications/aggregation。
在我的例子中,我在 Kettle 的 MongoDB Input 中使用了这个查询,我们还必须选择 Query is aggregation pipline。
{$match: {activity_type: " view "}},
{$sort: {activity_target: -1 } },
{$limit: 10}
以下屏幕截图可以帮助您更清楚地了解操作。