我正在尝试使用django和python开发mongodb聚合。

我有一个Atlas服务器，其数据库名为“ sucre”，其集合名为“ bdua”

在settings.py我有：

DATABASES = {
        'default': {
            'ENGINE': 'djongo',
            'NAME': 'morfeeweb',
            'ENFORCE_SCHEMA': False,
            'CLIENT': {
                'host': 'mongodb+srv://xxxxxx:xxxxxx@xxxxx.xxxxx.xxxxxx.mongodb.net/morfeeweb?retryWrites=true&w=majority',
                'port': 27017,
                'username': 'xxxxxx',
                'password': 'xxxxxxxx',
                'authSource': 'admin',
                'authMechanism': 'SCRAM-SHA-1'
            },
            'LOGGING': {
                'version': 1,
                'loggers': {
                    'djongo': {
                        'level': 'DEBUG',
                        'propagate': False,                        
                    }
                },
             },
        },
        'sucre': {
            'ENGINE': 'djongo',
            'NAME': 'sucre',
            'ENFORCE_SCHEMA': False,
            'CLIENT': {
                'host': 'mongodb+srv://xxxx:xxxxxx@xxxxx.xxxxx.xxxx.mongodb.net/sucre?retryWrites=true&w=majority',
                'port': 27017,
                'username': 'xxxxx',
                'password': 'xxxxxxxx',
                'authSource': 'admin',
                'authMechanism': 'SCRAM-SHA-1'
            },
            'LOGGING': {
                'version': 1,
                'loggers': {
                    'djongo': {
                        'level': 'DEBUG',
                        'propagate': False,                        
                    }
                },
             },
        }
    }

views.py

from django.contrib.auth.decorators import login_required
from django.shortcuts import render
from django.http import HttpResponse, JsonResponse
from random import randint

from django.db import connection

@login_required(login_url='/admin/login')
def consolidado(request):

    aggretation_sample = connection['sucre'].db.bdua.aggregate([
            {
            '$match': {'estado': 'AC', 'regimen': 'subsidiado'}
            },
            {
            '$group': { '_id': '$cod_EPS', 'Afiliados': {'$sum': 1}}
            },
            {
            '$sort': {'Afiliados': -1}
            }
            ])

    return HttpResponse(aggretation_sample)

它返回“ / aseguramiento /处的TypeError /'DefaultConnectionProxy'对象无法下标”

请帮忙

解决方案

django.db.connection返回default数据库（请参阅此处的文档）。您要使用：

from django.db import connections

aggretation_sample = connections['sucre']...