Quiero agrupar todos los documentos de acuerdo con un campo, pero restringir el número de documentos agrupados para cada valor.

Cada mensaje tiene un ID de conversación. Necesito obtener 10 o menos mensajes para cada ID de conversación.

Puedo agrupar de acuerdo con el siguiente comando, pero no puedo entender cómo restringir el número de documentos agrupados aparte de dividir los resultadosMessage.aggregate({'$group':{_id:'$conversation_ID',msgs:{'$push':{msgid:'$_id'}}}})

¿Cómo limitar la longitud de la matriz de mensajes para cada conversación_ID a 10?