Skip to main content

mq-bridge-pulsar (Python)

An Apache Pulsar endpoint for mq-bridge-py, shipped as a native plugin. The package contains no Python implementation of Pulsar — it bundles the compiled Rust endpoint and registers it with mq-bridge, so Python, Node.js and Rust all run the same code and the same delivery semantics.

pip install mq-bridge-py mq-bridge-pulsar
import mq_bridge
import mq_bridge_pulsar

mq_bridge_pulsar.register()   # call once, before starting routes

route = mq_bridge.Route.from_str("""
pulsar_to_file:
  input:
    custom:
      name: pulsar
      config:
        url: "pulsar://localhost:6650"
        topic: "persistent://public/default/orders"
        subscription: "order-workers"
  output:
    file:
      path: "orders.jsonl"
""")
route.start()

register() returns the endpoint name (pulsar) and is a no-op when called again. It raises ImportError if mq-bridge is missing and FileNotFoundError if the wheel does not carry a library for this platform.

The two packages are independent: mq-bridge has no Pulsar dependency, and neither package forces an upgrade of the other. A plugin is native code with the same privileges as the interpreter — install it as you would any other native dependency.

The generic wheel builder is supplied by mq-bridge:

pip install "mq-bridge-py[plugin-packaging]"
python -m mq_bridge.plugin_packaging --package python/mq_bridge_pulsar --out dist

Building the wheel

The generic builder shipped by mq-bridge builds the Rust cdylib, stages it into the package, and tags the wheel for the host platform:

python -m mq_bridge.plugin_packaging --package python/mq_bridge_pulsar --out dist

Run it once per operating system and architecture you publish for; building pulsar-rs needs protoc on PATH.

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distributions

No source distribution files available for this release.See tutorial on generating distribution archives.

Built Distributions

If you're not sure about the file name format, learn more about wheel file names.

mq_bridge_pulsar-0.1.3-py3-none-win_amd64.whl (1.7 MB view details)

Uploaded Python 3Windows x86-64

mq_bridge_pulsar-0.1.3-py3-none-manylinux_2_38_aarch64.whl (4.0 MB view details)

Uploaded Python 3manylinux: glibc 2.38+ ARM64

mq_bridge_pulsar-0.1.3-py3-none-manylinux_2_34_x86_64.whl (4.2 MB view details)

Uploaded Python 3manylinux: glibc 2.34+ x86-64

mq_bridge_pulsar-0.1.3-py3-none-macosx_11_0_arm64.whl (1.8 MB view details)

Uploaded Python 3macOS 11.0+ ARM64

mq_bridge_pulsar-0.1.3-py3-none-macosx_10_9_x86_64.whl (1.8 MB view details)

Uploaded Python 3macOS 10.9+ x86-64

File details

Details for the file mq_bridge_pulsar-0.1.3-py3-none-win_amd64.whl.

File metadata

File hashes

Hashes for mq_bridge_pulsar-0.1.3-py3-none-win_amd64.whl
Algorithm Hash digest
SHA256 7973eccc6b99b0154f0419982aa34a379587708a6b6aca2ab1b1bcc00bacd3cb
MD5 b02bf0cb0f2954aa199f087cd76b4291
BLAKE2b-256 ce027ea36cba8357b9d01f0a34b16946ce6ada12bc08bb52592227cc5be848db

See more details on using hashes here.

Provenance

The following attestation bundles were made for mq_bridge_pulsar-0.1.3-py3-none-win_amd64.whl:

Publisher: release.yml on marcomq/mq-bridge-pulsar

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file mq_bridge_pulsar-0.1.3-py3-none-manylinux_2_38_aarch64.whl.

File metadata

File hashes

Hashes for mq_bridge_pulsar-0.1.3-py3-none-manylinux_2_38_aarch64.whl
Algorithm Hash digest
SHA256 d22ec2fa6fe9a0fb851b24b03f268007c494cc1723003ced30da41402725f7c0
MD5 80da8e6547531d702c9016e6e8d37fb5
BLAKE2b-256 e1d52f024ac3b482e09bb26b141f66251da039ba0ef8d5fe4003218be31b4e08

See more details on using hashes here.

Provenance

The following attestation bundles were made for mq_bridge_pulsar-0.1.3-py3-none-manylinux_2_38_aarch64.whl:

Publisher: release.yml on marcomq/mq-bridge-pulsar

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file mq_bridge_pulsar-0.1.3-py3-none-manylinux_2_34_x86_64.whl.

File metadata

File hashes

Hashes for mq_bridge_pulsar-0.1.3-py3-none-manylinux_2_34_x86_64.whl
Algorithm Hash digest
SHA256 651f31862a6be68063aec5c5fc87114cf6a3b29b31a13b9333d86f17e548de98
MD5 0c275165b1503aca2bfa1e9375343cef
BLAKE2b-256 d47f5de9494751c10fcc9df84ef7774b8fc23f44dd230311df48bd34c5b2458c

See more details on using hashes here.

Provenance

The following attestation bundles were made for mq_bridge_pulsar-0.1.3-py3-none-manylinux_2_34_x86_64.whl:

Publisher: release.yml on marcomq/mq-bridge-pulsar

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file mq_bridge_pulsar-0.1.3-py3-none-macosx_11_0_arm64.whl.

File metadata

File hashes

Hashes for mq_bridge_pulsar-0.1.3-py3-none-macosx_11_0_arm64.whl
Algorithm Hash digest
SHA256 5cfedf7c258d9b8457ae4ea22383ccf18200a3f50a9b02f53c389b2e90f47af0
MD5 f7a949f0a3aecd17ae0135abacc8011d
BLAKE2b-256 85cf24cbfb33545bf8cd3adba594dbfb87f58fad593cae0116178978b9df466b

See more details on using hashes here.

Provenance

The following attestation bundles were made for mq_bridge_pulsar-0.1.3-py3-none-macosx_11_0_arm64.whl:

Publisher: release.yml on marcomq/mq-bridge-pulsar

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file mq_bridge_pulsar-0.1.3-py3-none-macosx_10_9_x86_64.whl.

File metadata

File hashes

Hashes for mq_bridge_pulsar-0.1.3-py3-none-macosx_10_9_x86_64.whl
Algorithm Hash digest
SHA256 7210e4234406bb11c14a01519a1e50cbba985025320b9102d4c2fa3cd3ad27c0
MD5 66dfb0f05b96220f2499c702f70eafa0
BLAKE2b-256 ad244beff6f6906acd9eb4d988c8cb73368ea0a149568057ce681e55f929a9c5

See more details on using hashes here.

Provenance

The following attestation bundles were made for mq_bridge_pulsar-0.1.3-py3-none-macosx_10_9_x86_64.whl:

Publisher: release.yml on marcomq/mq-bridge-pulsar

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Release history Release notifications | RSS feed

0.1.4

5 files

This release

0.1.3 This release

5 files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page