views.py 文件源码

def import_dataset(request):
    parameters = {key: (value if not isinstance(value, list) else value[0]) for key, value in request.POST.items()}

    parameters['directory'] = prepare_import_directory(IMPORTER_DIRECTORY)
    parameters['elastic_url'] = es_url

    if DocumentStorer.exists(**parameters):
        return HttpResponse('Index and mapping exist', status=403)

    if parameters['format'] not in {'postgres', 'mongodb', 'elastic'}:
        if 'file' in request.FILES:
            fs = FileSystemStorage(location=parameters['directory'])
            file_name = fs.save(request.FILES['file'].name, request.FILES['file'])
            parameters['file_path'] = fs.path(file_name)
        elif 'url' not in parameters:
            return HttpResponse('failed')

    Process(target=_import_dataset, args=(parameters,)).start()

    return HttpResponse()