Skip to main content

Salesforce Streaming API client for asyncio

Project description

aiosfstream

PyPI package Documentation Status Build status Coverage MIT license

aiosfstream is a Salesforce Streaming API client for asyncio. It can be used to receive push notifications about changes on Salesforce objects or notifications of general events sent through the Streaming API.

For detailed guidance on how to work with PushTopics or how to create Generic Streaming Channels please consult the Streaming API documentation. For working with Platform Events or Change Data Capture events check out the linked documentation.

Features

Usage

import asyncio

from aiosfstream import SalesforceStreamingClient


async def stream_events():
    # connect to Streaming API
    async with SalesforceStreamingClient(
            consumer_key="<consumer key>",
            consumer_secret="<consumer secret>",
            username="<username>",
            password="<password>") as client:

        # subscribe to topics
        await client.subscribe("/topic/one")
        await client.subscribe("/topic/two")

        # listen for incoming messages
        async for message in client:
            topic = message["channel"]
            data = message["data"]
            print(f"{topic}: {data}")

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(stream_events())

Documentation

http://aiosfstream.readthedocs.io/

Changelog

0.5.0 (2019-03-08)

  • Add support for Change Data Capture events

  • Fix some typos in the documentation

0.4.0 (2019-01-06)

  • Add type hints

  • Configurable replay storage behavior

0.3.0 (2018-11-07)

  • Add support for sandbox orgs

0.2.5 (2018-11-06)

  • Add missing changelog entries

0.2.4 (2018-11-06)

  • Fix platform event message creation date extraction issue

0.2.3 (2018-09-19)

  • Fix asynchronous iterator bug in python 3.7

0.2.2 (2018-06-15)

  • Update aiocometd dependency to 0.3.1

0.2.1 (2018-05-25)

  • Fix replay issues on mass record delete operations

  • Improve the documentation of the Client.publish method

0.2.0 (2018-05-05)

  • Enable the usage of third party JSON libraries

  • Expose authentication results as public attributes in Authenticator classes

0.1.0 (2018-04-26)

Project details


Download files

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

Source Distribution

aiosfstream-0.5.0.tar.gz (62.8 kB view details)

Uploaded Source

Built Distribution

aiosfstream-0.5.0-py3-none-any.whl (16.3 kB view details)

Uploaded Python 3

File details

Details for the file aiosfstream-0.5.0.tar.gz.

File metadata

  • Download URL: aiosfstream-0.5.0.tar.gz
  • Upload date:
  • Size: 62.8 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/1.12.1 pkginfo/1.4.2 requests/2.21.0 setuptools/39.0.1 requests-toolbelt/0.8.0 tqdm/4.28.1 CPython/3.7.0

File hashes

Hashes for aiosfstream-0.5.0.tar.gz
Algorithm Hash digest
SHA256 9f15e766d29e98e9bd817ad2cb9c1c8ca6384727b875a4f051293310162e7964
MD5 371ed9c88fe5dda68bb0d7f314d68015
BLAKE2b-256 dfb2969d2e5b4ba7ed2d190ffa019d74e775fecf40b9402e8974e6cb471fe58b

See more details on using hashes here.

File details

Details for the file aiosfstream-0.5.0-py3-none-any.whl.

File metadata

  • Download URL: aiosfstream-0.5.0-py3-none-any.whl
  • Upload date:
  • Size: 16.3 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/1.12.1 pkginfo/1.4.2 requests/2.21.0 setuptools/39.0.1 requests-toolbelt/0.8.0 tqdm/4.28.1 CPython/3.7.0

File hashes

Hashes for aiosfstream-0.5.0-py3-none-any.whl
Algorithm Hash digest
SHA256 e8a251ae3d33f6cd9d522d27be23c234b56cf7b6d2a151376f359f7e0b08e0b4
MD5 af6f759dc9dee634b8f93426935a6a78
BLAKE2b-256 6082947528d182b7214a3f67100ad6c7e5c2dcfc5d4103d2c374bf6f83ee4d89

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page