Benutzerdefinierte Speichersystem für GridFS (MongoDB)?

Question

Kann mir jemand Punkt auf alle Projekte / django-Anwendungen, die eine steckbare individuelle Speichersystem zur Verfügung stellen, damit ich GridFS mit Django verwenden Datei-Uploads zu speichern?

ich django-mongodb gefunden habe, aber es tut zu unterstützen GridFS scheinen, noch hat django-Speicher.

Ich plane mysql für die normale Datenbank requrements zu laufen und nur mongodb für die Dateispeicherung verwenden, so klar zu sein Ich möchte nicht verwenden mongodb als meine Haupt-Datenbank.

Answer 1

Ich arbeite auf PyMongo, die MongoDB Python-Treiber und nicht von jedem Projekt gehört benutzerdefinierten Speicher zur Verfügung zu stellen für Django GridFS verwenden. Das sieht aus wie es nicht sehr schwer sein würde, oben auf PyMongo zu schreiben: wahrscheinlich eine direkte Übersetzung des GridFS API auf die

Answer 2

I umgesetzt kürzlich die GridFS Unterstützung in Mongoengine , die dich zur Kasse. Dazu gehören ein Django Speicher-Backend, die Sie rechts in die Sie Projekte anschließen können und die Verwendung mit Imagefield etc. Ich bin diese Technologien in der Produktion und es hält bis groß, so weit.

django-mongodb-Motor einen Blick wert sein könnte, da es ermöglicht, Sie, dass ohne die Notwendigkeit zu tun, um Änderungen an den vorhandenen Django Code zu machen.

Ich brauchte genau das für Maya EDMS , steckbare Speicher und Datenbank-Trennung. Mit Michael Dirolf neuester PyMongo Bibliothek, war es ziemlich trivial eine Basisklasse zu erhalten gehen.

Um es zu verwenden:

from gridfsstorage import GridFSStorage
file = models.FileField(storage=GridFSStorage())

die gridfsstorage.py-Datei:

import os

from django.core.files.storage import Storage
from django.utils.encoding import force_unicode
from django.conf import settings

from pymongo import Connection
from gridfs import GridFS

class GridFSStorage(Storage):
    def __init__(self, *args, **kwargs):
        self.db = Connection(host=settings.GRIDFS_HOST,
            port=settings.GRIDFS_PORT)[settings.DATABASE_NAME]
        self.fs = GridFS(self.db)


    def save(self, name, content):
        while True:
            try:
                # This file has a file path that we can move.
                if hasattr(content, 'temporary_file_path'):
                    self.move(content.temporary_file_path(), name)
                    content.close()
                # This is a normal uploadedfile that we can stream.
                else:
                    # This fun binary flag incantation makes os.open throw an
                    # OSError if the file already exists before we open it.
                    newfile = self.fs.new_file(filename=name)
                    try:
                        for chunk in content.chunks():
                            newfile.write(chunk)
                    finally:
                        newfile.close()
        except Exception, e:
            raise
        else:
            # OK, the file save worked. Break out of the loop.
            break

        return name


    def open(self, name, *args, **kwars):
        return self.fs.get_last_version(name)


    def delete(self, name):
        oid = self.fs.get_last_version(name)._id
        self.fs.delete(oid)


    def exists(self, name):
        return self.fs.exists(filename=name)        


    def path(self, name):
        return force_unicode(name)


    def size(self, name):
        return self.fs.get_last_version(name).length

    def move(self, old_file_name, name, chunk_size=1024*64):
        # first open the old file, so that it won't go away
        old_file = open(old_file_name, 'rb')
        try:
            newfile = self.fs.new_file(filename=name)

            try:
                current_chunk = None
                while current_chunk != '':
                    current_chunk = old_file.read(chunk_size)
                    newfile.write(current_chunk)
            finally:
                newfile.close()
        finally:
            old_file.close()

        try:
            os.remove(old_file_name)
        except OSError, e:
            # Certain operating systems (Cygwin and Windows) 
            # fail when deleting opened files, ignore it.  (For the 
            # systems where this happens, temporary files will be auto-deleted
            # on close anyway.)
            if getattr(e, 'winerror', 0) != 32 and getattr(e, 'errno', 0) != 13:
                raise

Answer 3

I umgesetzt kürzlich die GridFS Unterstützung in Mongoengine , die dich zur Kasse. Dazu gehören ein Django Speicher-Backend, die Sie rechts in die Sie Projekte anschließen können und die Verwendung mit Imagefield etc. Ich bin diese Technologien in der Produktion und es hält bis groß, so weit.

Answer 4

django-mongodb-Motor einen Blick wert sein könnte, da es ermöglicht, Sie, dass ohne die Notwendigkeit zu tun, um Änderungen an den vorhandenen Django Code zu machen.

Answer 5

Ich brauchte genau das für Maya EDMS , steckbare Speicher und Datenbank-Trennung. Mit Michael Dirolf neuester PyMongo Bibliothek, war es ziemlich trivial eine Basisklasse zu erhalten gehen.

Um es zu verwenden:

from gridfsstorage import GridFSStorage
file = models.FileField(storage=GridFSStorage())

die gridfsstorage.py-Datei:

import os

from django.core.files.storage import Storage
from django.utils.encoding import force_unicode
from django.conf import settings

from pymongo import Connection
from gridfs import GridFS

class GridFSStorage(Storage):
    def __init__(self, *args, **kwargs):
        self.db = Connection(host=settings.GRIDFS_HOST,
            port=settings.GRIDFS_PORT)[settings.DATABASE_NAME]
        self.fs = GridFS(self.db)


    def save(self, name, content):
        while True:
            try:
                # This file has a file path that we can move.
                if hasattr(content, 'temporary_file_path'):
                    self.move(content.temporary_file_path(), name)
                    content.close()
                # This is a normal uploadedfile that we can stream.
                else:
                    # This fun binary flag incantation makes os.open throw an
                    # OSError if the file already exists before we open it.
                    newfile = self.fs.new_file(filename=name)
                    try:
                        for chunk in content.chunks():
                            newfile.write(chunk)
                    finally:
                        newfile.close()
        except Exception, e:
            raise
        else:
            # OK, the file save worked. Break out of the loop.
            break

        return name


    def open(self, name, *args, **kwars):
        return self.fs.get_last_version(name)


    def delete(self, name):
        oid = self.fs.get_last_version(name)._id
        self.fs.delete(oid)


    def exists(self, name):
        return self.fs.exists(filename=name)        


    def path(self, name):
        return force_unicode(name)


    def size(self, name):
        return self.fs.get_last_version(name).length

    def move(self, old_file_name, name, chunk_size=1024*64):
        # first open the old file, so that it won't go away
        old_file = open(old_file_name, 'rb')
        try:
            newfile = self.fs.new_file(filename=name)

            try:
                current_chunk = None
                while current_chunk != '':
                    current_chunk = old_file.read(chunk_size)
                    newfile.write(current_chunk)
            finally:
                newfile.close()
        finally:
            old_file.close()

        try:
            os.remove(old_file_name)
        except OSError, e:
            # Certain operating systems (Cygwin and Windows) 
            # fail when deleting opened files, ignore it.  (For the 
            # systems where this happens, temporary files will be auto-deleted
            # on close anyway.)
            if getattr(e, 'winerror', 0) != 32 and getattr(e, 'errno', 0) != 13:
                raise