我是Python的新手,但我知道自动通过自动传递。我无法理解为什么我会遇到此错误,并且我在GetGraph函数上也遇到了相同的错误2需要1。这里出了什么问题?
createoc在celerytasks.pys.py和insert_manager中
@app.task
def createDoc(self):
print ("CeleryTasks:CreateDoc")
if 'refs' not in self.data:
return
print(self.data['refs'])
for id in self.data['refs']:
doc = self.db[self.collName].find_one({'_id': id})
if doc is None:
insertedID = self.db[self.collName].insert_one({
"_id": id
})
print (insertedID)
#Trigger on Mongo Operations
def insert_manager(op_document):
print("Data Inserted")
# pprint.pprint (op_document)
data = op_document['o']
ns = op_document['ns'].split('.')
# pprint.pprint (data)
docID = op_document['o']['_id']
tasks = CeleryTasks(port, docID, dbName, collectionName, data)
tasks.createDoc()
tasks.getGraph.delay(docID)
self
在类方法时始终传递。
芹菜任务是独立的功能。您可以通过app
装饰器添加bind=True
来添加self
参数,但用于不同的目的:有限任务