|
@@ -41,7 +41,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
|
|
self.mq_attachment = "/queue/dataflow_attachment"
|
|
self.mq_attachment = "/queue/dataflow_attachment"
|
|
self.mq_attachment_failed = "/queue/dataflow_attachment_failed"
|
|
self.mq_attachment_failed = "/queue/dataflow_attachment_failed"
|
|
self.mq_extract = "/queue/dataflow_extract"
|
|
self.mq_extract = "/queue/dataflow_extract"
|
|
- self.comsumer_count = 80
|
|
|
|
|
|
+ self.comsumer_count = 120
|
|
self.retry_comsumer_count = 10
|
|
self.retry_comsumer_count = 10
|
|
self.retry_times = 5
|
|
self.retry_times = 5
|
|
for _i in range(self.comsumer_count):
|
|
for _i in range(self.comsumer_count):
|
|
@@ -524,7 +524,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
self.industy_url = "http://127.0.0.1:15000/industry_extract"
|
|
self.industy_url = "http://127.0.0.1:15000/industry_extract"
|
|
|
|
|
|
self.extract_interfaces = [["http://127.0.0.1:15030/content_extract",15],
|
|
self.extract_interfaces = [["http://127.0.0.1:15030/content_extract",15],
|
|
- ["http://192.168.0.115:15030/content_extract",5]
|
|
|
|
|
|
+ ["http://192.168.0.115:15030/content_extract",8]
|
|
]
|
|
]
|
|
|
|
|
|
|
|
|