salsão fila de tarefa distribuída para Django
Baixe Agora

salsão Classificação e resumo

salsão Tag

fila tarefa estrutura Plugin Django Framework da fila Fila de tarefa.

salsão Descrição

Fila de tarefa distribuída para Django Aipo é uma estrutura de fila de tarefa distribuída para DJANGO.InstallationYou pode instalar o aipo através do índice Python Package (PYPI) ou de Source.Para instalar usando pip ,: $ pip instalar celeryto instalar usando fácil_install, você fez o download de uma fonte Tarball você pode instalá-lo fazendo o seguinte: $ python setup.py build # python setup.py instalar # como rootusagehave para escrever um tutorial legal, mas aqui é alguns itens de uso simples.Nota você precisa ter um corretor de mensagens amqp em execução , como o Rabbitmq, e você precisa ter a configuração do servidor AMQP em seu arquivo de configurações, conforme descrito na distribuição de cenoura Readme.note Se você estiver executando o SQLite como o back-end banco de dados, o Celeryd só poderá processar uma mensagem de cada vez , isso porque o SQLite não permite as tarefas simultâneas .Defining >>> da Aipo.Task Tarefas de Import >>> do Aipo.Log Import Setup_logger >>> def do_something (some_arg, ** kwargs): ... logger = setup_logger (** kwargs) ... logger.info ("fez algo :% s "% ste_arg) >>> Task.Register (Do_Something," Do_Something ") Nota As funções de tarefas suporta apenas argumentos de palavra-chave.Tell o daemon de aipo para executar uma tarefa >>>>>>>>>>>>>>>>>>>>>>>>>>>>> "Do_Something", some_arg = "foo bar Baz") Executando o daemon de aipo $ CD MyDjangoProjeco $ Env Django_Settings_Module = Configurações Celeryd Algo: Foo Bar BAZ Esperando por fila.AuTodiscovery of TaskScelery tem um recurso de tarefas como o administrador Django, que carrega automaticamente qualquer módulo Tarefas.py nos aplicativos listados em settings.installed_apps.a bom lugar para adicionar este comando pode estar no seu URLS.py, da Aipo.Task Importar Taskstasks.AutoDiscover (), então você pode adicionar novas tarefas em seus aplicativos Tasks.py módulo, da Aipo TasksFrom Celery .log import setup_loggerfrom clickcounter.models Importar ClickCountDEF increment_Click (for_url, ** kwargs): logger = setup_logger (** kwargs clicks_for_url, cr = clickcount.objects.get_or_create (URL = for_url) clicks_for_url.clicks = clicks_for_url.clicks = clicks_for_url.clicks + 1 clicks_for_url.save () logger.info ("Configamento de clique incrementado para% s (não em% d)"% (for_url , clicks_for_url.clicks) Tasks.Register (increment_click, "increment_click") tarefas periódicas Tasksperiodic são tarefas que são executadas a cada n segundos. Eles não suportam argumentos extras. Aqui está um exemplo de uma tarefa periódica: >>> da aipo.Task Tasks de importação, periodstask >>> da Datetime Import TimeDelta >>> Classe MyperiodTASK (PeriodTask): ... Nome = "Foo.My-periódico-tarefa". .. run_every = timedelta (segundos = 30) ... ... def executar (auto, ** kwargs): ... logger = self.get_logger (** kwargs) ... logger.info ("Tarefa periódica em execução ! ") ... >>> Tasks.Register (MyperiodTASK) Para tarefas periódicas para funcionar, você precisa adicionar aipo a instalação_apps e emitir um syncdb. Requisitos: · Pitão · Django. O que há de novo nesta versão: · Está ficando bastante estável, com muitos novos recursos, então a versão de Bump para 0,2. Este é um pré-lançamento. · Aipo.Task.mark_as_read () e aipo.Task.mark_as_failure () foi removido. Use aipo.backends.default_backend.mark_as_read () e aipo.backends.default_backend.mark_as_failure () em vez disso.

salsão Software Relacionado