nameko-salesforce 1.2.0

快速入门

从PyPI安装

pip install nameko-salesforce

创建一个处理Salesforce联系人对象更改的服务，并具有创建Salesforce中新的联系人对象的RPC端点

# service.py

from nameko.rpc import rpc
from nameko_salesforce.streaming import handle_sobject_notification
from nameko_salesforce.api import SalesforceAPI

class Service:

    name = 'some-service'

    salesforce = SalesforceAPI()

    @handle_sobject_notification('Contact', exclude_current_user=False)
    def handle_contact_updates(
        self, sobject_type, record_type, notification
    ):
    """ Handle Salesforce contacts updates
    """
    print(notification)

    @rpc
    def create_contact(self, last_name, email_address):
    """ Create a contact in Salesforce
    """
    self.salesforce.Contact.create(
        {'LastName': last_name,'Email': email_address})

创建一个包含基本设置的配置文件

# config.yaml

AMQP_URI: 'pyamqp://guest:guest@localhost'
SALESFORCE:
    USERNAME: ${SALESFORCE_USERNAME}
    PASSWORD: ${SALESFORCE_PASSWORD}
    SECURITY_TOKEN: ${SALESFORCE_SECURITY_TOKEN}
    SANDBOX: False

运行服务并提供您的Salesforce凭据

$ SALESFORCE_USERNAME=rocky \
  SALESFORCE_PASSWORD=*** \
  SALESFORCE_SECURITY_TOKEN=*** \
  nameko run --config config.yaml service

最后，在另一个shell中调用RPC端点以创建新用户

$ nameko shell --config config.yaml
In [1]: n.rpc['some-service'].create_contact('Yo', 'yo@yo.yo')

您应该在Salesforce中看到创建的新联系人，并且您的服务应该收到通知。在第一个shell中，您将找到打印的通知。

{'event': {'replayId': 1, 'type': 'created' ...

欲了解更多信息，请参阅文档。