google app engine上的kafka producer

ff29svar  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(302)

我有一个python谷歌应用引擎项目。我想使用库kafkapython将kafkaproducer集成到该项目中(我完全能够通过python控制台直接运行kafkapython)。使用google app engine sdk在本地运行时,我在python2.7多处理库中遇到以下错误:

Traceback (most recent call last):
File "/usr/local/google_appengine/google/appengine/runtime/wsgi.py", line 240, in Handle
handler = _config_handle.add_wsgi_middleware(self._LoadHandler())
File "/usr/local/google_appengine/google/appengine/runtime/wsgi.py", line 299, in _LoadHandler
handler, path, err = LoadObject(self._handler)
File "/usr/local/google_appengine/google/appengine/runtime/wsgi.py", line 85, in LoadObject
obj = __import__(path[0])
File "/Users/nilaysahu/Documents/abc/booking_management/main.py", line 29, in <module>
from modules.booking.handlers.test_handler import TestHandler
File "/Users/nilaysahu/Documents/abc/booking_management/modules/booking/handlers/test_handler.py", line 5, in <module>

**from kafka import KafkaProducer**

File "/Users/nilaysahu/Documents/abc/booking_management/lib/kafka/__init__.py", line 19, in <module>
from kafka.consumer import KafkaConsumer
File "/Users/nilaysahu/Documents/abc/booking_management/lib/kafka/consumer/__init__.py", line 2, in <module>
from .multiprocess import MultiProcessConsumer
File "/Users/nilaysahu/Documents/abc/booking_management/lib/kafka/consumer/multiprocess.py", line 5, in <module>
from multiprocessing import Process, Manager as MPManager
File "/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/multiprocessing/__init__.py", line 65, in <module>
from multiprocessing.util import SUBDEBUG, SUBWARNING
File "/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/multiprocessing/util.py", line 41, in <module>
from subprocess import _args_from_interpreter_flags

**ImportError: cannot import name _args_from_interpreter_flags**

我的本地框架有问题吗?
谷歌应用引擎(不是计算引擎)支持Kafka吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题