ListDataStreamExports

Retrieves the list of YDS exports for the specified registry.

TypeScript

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

const ListDataStreamExportsRequest =
  cloudApi.iot.devices_registry_service.ListDataStreamExportsRequest;

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

  const result = await client.listDataStreamExports(
    ListDataStreamExportsRequest.fromPartial({
      registryId: "registryId",
    })
  );
  console.log(result);
})();

Python

import os
import grpc
import yandexcloud

from yandex.cloud.iot.devices.v1.registry_service_pb2 import ListDataStreamExportsRequest
from yandex.cloud.containerregistry.v1.registry_service_pb2_grpc import RegistryServiceStub

token = os.getenv("YC_OAUTH_TOKEN")

sdk = yandexcloud.SDK(token=token)

service = sdk.client(RegistryServiceStub)
response = service.ListDataStreamExports(ListDataStreamExportsRequest(registry_id="registryId"))
print(response)

ListDataStreamExportsRequest

registryId : string

ID of the registry to list YDS exports in.

To get a registry ID make a RegistryService.List request.

ListDataStreamExportsResponse

dataStreamExports : DataStreamExport

List of YDS exports for the specified registry.

DataStreamExport

A Yandex Data Streams export.

id : string

ID of the YDS export.

name : string

Name of the YDS export.

registryId : string

ID of the registry that the YDS export belongs to.

mqttTopicFilter : string

MQTT topic whose messages export to YDS.

database : string

YDS database.

stream : string

YDS stream name.

serviceAccountId : string

ID of the service account which has permission to write to data stream.

createdAt : google.protobuf.Timestamp

Creation timestamp.

---