首页 > 解决方案 > 芹菜任务成功但结果显示无

问题描述

from __future__ import division
from math import log, exp
from operator import mul
from math import e
from collections import Counter
import os
import pylab, json, csv
import pickle
from celery import Celery

app = Celery('sentiment_worker_test',backend='amqp', broker='amqp://localhost//')

pos = dict()
neg = dict()
features = set()
totals = [0, 0]
delchars = ''.join(c for c in map(chr, range(128)) if not c.isalnum())

CDATA_FILE = "countdata.pickle"

class MyDict(dict):
    def __getitem__(self, key):
        if key in self:
            return self.get(key)
        return 0

    def __init__(self):
        self.train()
        # print "Trained..."

    def negate_sequence(self,text):
        """
        Detects negations and transforms negated words into "not_" form.
        """
        #some code 


    def train(self):
        #some code

    def classify2(self, text):
        #some code

    @app.task(bind=True)
    def classify_demo(self, input_data):
        #some code

if __name__ == '__main__':
    query = "Some String to test"

    result = MyDict().classify_demo.delay(query)
    print (result.get())
    print

我正在使用这个命令在我的 Windows 7 电脑上运行 celery 任务:

芹菜 -A 情绪工作者测试工作者 -l 信息 -P 事件

全部显示并成功连接...

但是当我使用命令在另一个终端中运行这个 Sentiment_worker_test.py 文件时:“python Sentiment_worker_test.py”然后它在结果中显示“None”......

并在 celery 命令提示符窗口中显示以下响应..

[2018-10-31 11:19:13,104:INFO/MainProcess] celery@dell-PC 准备就绪。[2018-10-31 11:19:13,105:INFO/MainProcess] 收到的任务:sentiment_worker_test .classify_demo[4d173818-64f6-400a-a75b-344074921461] [2018-10-31 11:19:13,107:警告/MainProcess]是一些错误,请使用不同的输入重试 [2018-10-31 11:19:13,108: INFO/MainProcess] pidbox: Connected toamqp://guest:**@127.0.0.1:5672//。[2018-10-31 11:19:13,221: INFO/MainProcess] 任务感测_worker_test.classify_demo[4d173818-64f6-400a-a75b-344074921461] 0.10899999999946886s 成功:无

我不知道那个警告是什么意思......“有一些错误,请用不同的输入重试”..我已经尝试了几乎所有不同类型的输入......但没有一个工作......

任何帮助,将不胜感激

提前致谢

标签: python-3.xcelery

解决方案


推荐阅读