Publish

Publishes message on behalf of specified registry

TypeScript

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

const PublishRegistryDataRequest =
  cloudApi.iot.devices_registry_data_service.PublishRegistryDataRequest;

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

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

Python

import os
import grpc
import yandexcloud

from yandex.cloud.iot.devices.v1.registry_data_service_pb2 import PublishRegistryDataRequest
from yandex.cloud.iot.devices.v1.registry_data_service_pb2_grpc import RegistryDataServiceStub

token = os.getenv("YC_OAUTH_TOKEN")

sdk = yandexcloud.SDK(token=token)

service = sdk.client(RegistryDataServiceStub)
response = service.Publish(
    PublishRegistryDataRequest(
        registry_id="registryId",
        topic="topic",
        # data = b''
    )
)
print(response)

PublishRegistryDataRequest

registryId : string

ID of registry publishing message

topic : string

Topic where message should be published

data : bytes

Content of the message

PublishRegistryDataResponse

---