Publish

Publishes message on behalf of specified broker

TypeScript

import { cloudApi, serviceClients, Session } from "@yandex-cloud/nodejs-sdk";

const PublishBrokerDataRequest =
  cloudApi.iot.broker_broker_data_service.PublishBrokerDataRequest;

(async () => {
  const authToken = process.env["YC_OAUTH_TOKEN"];
  const session = new Session({ oauthToken: authToken });
  const client = session.client(serviceClients.BrokerDataServiceClient);

  const result = await client.publish(
    PublishBrokerDataRequest.fromPartial({
      brokerId: "brokerId",
      topic: "topic",
      // data: Buffer.from([])
    })
  );
  console.log(result);
})();

Python

import os
import grpc
import yandexcloud

from yandex.cloud.iot.broker.v1.broker_data_service_pb2_grpc import BrokerDataServiceStub
from yandex.cloud.iot.broker.v1.broker_data_service_pb2 import PublishBrokerDataRequest

token = os.getenv("YC_OAUTH_TOKEN")

sdk = yandexcloud.SDK(token=token)

service = sdk.client(BrokerDataServiceStub)
response = service.Publish(
    PublishBrokerDataRequest(
        broker_id="brokerId",
        topic="topic",
        # data = b''
    )
)
print(response)

PublishBrokerDataRequest

brokerId : string

ID of broker publishing message

topic : string

Topic where message should be published

data : bytes

Content of the message

PublishBrokerDataResponse

---