Описание тега python-pulsar
Параллельная среда, управляемая событиями, для Python.
0
ответов
Как запустить Spark 2.3 Streaming Pulsar Receiver в Python(PySpark)
Я использую python в качестве языка бэкэнда и хочу запустить spark в качестве приемника потоковых данных от Pulsar. Все, что я нашел, это. Похоже, в настоящее время поддерживается только Java. Можно ли заставить его работать в python (т.е. pyspark)?…
10 апр '18 в 15:26
1
ответ
WSGI-совместимый компонент с клиентом веб-сокета?
Я пытаюсь интегрировать респондент RESTful в приложение Crossbar, для которого лучше всего подходит служба WSGI. В идеале, эта служба должна быть частью остальной инфраструктуры pub/sub, чтобы иметь возможность получать события WAMP с одной стороны …
16 фев '15 в 07:40
1
ответ
Python 3.5 асинхронное ключевое слово
Я сейчас смотрю в pulsar для асинхронного HTTP-клиента. Следующий пример находится в документации: from pulsar.apps import http async with http.HttpClient() as session: response1 = await session.get('https://github.com/timeline.json') response2 = aw…
04 мар '17 в 15:04
1
ответ
Как настроить python-pulsar с apache
Попытка работать с платформой параллельной обработки пульсара Django Python. Сервер wsgi предоставлен pulsar может быть использован через командную строку как $python manage.py pulse который в основном запускает HTTP-сервер WSGI, похожий на сервер р…
18 окт '13 в 15:06
1
ответ
Как отловить TimeoutError с помощью Pulsar HttpClient с Tornado
Я пишу приложение, используя Торнадо. Мне нужно сделать много HTTP-запросов, но HTTP-клиент Tornado немного отстой (не поддерживает Keep-Alive и работает медленно), поэтому я пытаюсь использовать Pulsar HttpClient: import tornado.web import tornado.…
27 авг '15 в 12:09
1
ответ
Pulsar: Ошибка проверки / получения метаданных раздела при подписке на постоянные://public/default/test
У меня сейчас есть docker-compose.yml файл, который вызывает ряд услуг. Одним из таких сервисов является пульсар, а другим - веб-сервер, подключенный через веб-сокет. Когда я поднимаю эти сервисы, контейнер websocket не работает. Это логи говорят: E…
15 май '19 в 14:39
0
ответов
Ошибка импорта concurrent.futures и AsyncObject. Нужно исправить
Привет у меня есть эта ошибка: из concurrent.futures импортировать AsyncObject ImportError: невозможно импортировать имя 'AsyncObject' и я не знаю, как это исправить. Любая помощь / решения приветствуются. Спасибо
02 июл '19 в 18:44
2
ответа
Пулсар-клиент не может быть установлен
Я не могу установить pulsar-client как это вообще упоминается в документации: pip3 install pulsar-client Сбор pulsar-client ОШИБКА: не удалось найти версию, которая удовлетворяет требованию pulsar-client (из версий: нет) ОШИБКА: Не найдено соответст…
16 июл '19 в 16:00
0
ответов
Ошибка Нет такого файла или каталога: _pulsar.so
При установке pulsar-client для питона, выполнив следующие шаги $ git clone https://github.com/apache/pulsar $ cd pulsar/pulsar-client-cpp/python $ sudo python setup.py install столкнулся с ошибкой Нет такого файла или каталога: _pulsar.so
26 июл '19 в 13:01
1
ответ
Публикация в теме с зарегистрированной схемой в Apache Pulsar
Как показано в примере в документации реестра Pulsar Schema Producer<User> producer = client.newProducer(JSONSchema.of(User.class)) .topic(topic) .create(); User user = new User(“Tom”, 28); producer.send(User); Вы можете зарегистрировать схему…
23 окт '19 в 16:06
1
ответ
Не удалось установить соединение с поддержкой TLS с брокером в автономном кластере Apache Pulsar
Я настроил broker.conf и попытался создать клиента с включенным tls. Буквально я правильно указал пути сертификатов. Когда я пытаюсь запустить клиент, появляется следующая ошибка. 2019-09-27 13:30:36.586 INFO ConnectionPool:72 | Created connection f…
27 сен '19 в 11:18
0
ответов
Исключения функций в Pulsar (PUB-SUB)
Мне нужна помощь с исключениями функций Pulsar, что такое исключения пользовательских функций и что произойдет, если их частота / счет будет высока, а также что может быть причиной высокой частоты / счетчика.
27 фев '20 в 10:51
1
ответ
Установка Apache Pulsar в Windows Docker
Не могли бы вы помочь мне, как установить локальный автономный кластер Pulsar с помощью Windows docker. Я выполнил следующие варианты. Но я не смог получить доступ к пользовательскому интерфейсу Pulsar Порт 8080 уже выделен для какого-то другого про…
08 июн '20 в 09:09
1
ответ
Создание Key_Shared Consumer Apache Pulsar
Я использую клиенты Apache Pulsar Python для подключения своих микросервисов. Я хочу создать Key_Shared Consumer, который делает следующее: import pulsar,_pulsar client = pulsar.Client('pulsar://localhost:6650') consumer = client.subscribe('my-topic…
04 июн '20 в 19:27
0
ответов
Настройка библиотек Apache Pulsar и Python на корпоративном компьютере с Windows 10 или Pycharm IDE
Не могли бы вы помочь мне настроить настройку python pulsar в среде разработки pycharm или любые другие параметры на машине с Windows 10. У меня есть это в Google, и я не получил никакой информации об этом. будет очень полезно, если кто-нибудь подел…
21 июн '20 в 17:04
0
ответов
Есть ли способ подтвердить все сообщения до последнего сообщения в очереди?
В случае, когда потребительский процесс умирает, я хотел бы перезапустить его и удалить / подтвердить все предыдущие сообщения в невыполненном журнале и обработать только последнее сообщение. Как лучше всего сделать это в клиенте Python.
21 июн '20 в 16:04
1
ответ
Pulsar GoClient Эквивалент unacked_messages_timeout_ms (py-client)
В Pulsar Python Client есть опция подписчика unacked_messages_timeout_ms для установки интервала, по истечении которого незапакованные сообщения будут доставлены повторно. Что эквивалентно этому в Pulsar Go Client? Python py_consumer = client.subscr…
31 авг '21 в 22:59
1
ответ
Как сказать потребителю Python ждать загрузки клиента
У меня фундаментальная проблема в контейнере докеров, когда я пытаюсь начать создавать и запускать два изображения, где второе изображение (python и некоторые сценарии) зависит от первого изображения. Это вызывает ошибку и остановку второго изображе…
12 окт '21 в 22:13
1
ответ
Как работать с сообщениями схемы protobuf в пакете Python Apache pulsar pulsar-client?
Есть ли способ опубликовать сообщение в теме Apache Pulsar, используя схему Protobuf, используя пакет pulsar-client с использованием python? Согласно документации, он поддерживает только Avro, String, Json и байты. Любая работа для этого?https://pul…
12 янв '22 в 20:19
1
ответ
Исключение: ошибка Pulsar: несовместимая схема
Я новичок в Pulsar и просто изучаю функциональные возможности нового проекта. Я пытаюсь использовать очень простой пример для отправки данных от производителя на основе схемы. Чтобы дать некоторую информацию, моя идея состоит в том, чтобы отправить …
11 фев '22 в 19:17