Put

Puts event to bus.

TypeScript

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

const PutEventRequest =
  cloudApi.serverless.eventrouter_event_service.PutEventRequest;

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

  const result = await client.put(
    PutEventRequest.fromPartial({
      busId: "busId",
      body: "body",
    })
  );
  console.log(result);
})();

Python

import os
import grpc
import yandexcloud

from yandex.cloud.serverless.eventrouter.v1.event_service_pb2_grpc import EventServiceStub
from yandex.cloud.serverless.eventrouter.v1.event_service_pb2 import PutEventRequest

token = os.getenv("YC_OAUTH_TOKEN")

sdk = yandexcloud.SDK(token=token)

service = sdk.client(EventServiceStub)
response = service.Put(PutEventRequest(bus_id="busId", body="body"))
print(response)

PutEventRequest

busId : string

ID of the bus to put event.

body : string

Event body.

Empty

---