Getting started

Get started by connecting your application to EventStoreDB.

Connecting to EventStoreDB

For your application to start communicating with EventStoreDB, you need to instantiate the client and configure it accordingly. Below are instructions for supported SDKs.

Required packages

Install the client SDK package to your project.

Python

Install the esdbclient package from PyPI or use Poetry:

pip install esdbclient

poetry add esdbclient

NodeJS

Install the @eventstore/db-client package using NPM, Yarn or PNPM:

npm install --save @eventstore/db-client

yarn add @eventstore/db-client

pnpm add @eventstore/db-client

TypeScript Declarations are included in the package.

Java

Add the db-client-java dependency to your Maven or Gradle project:

<dependency>
  <groupId>io.kurrent</groupId>
  <artifactId>db-client-java</artifactId>
  <version>5.2.0</version>
</dependency>

implementation 'io.kurrent:db-client-java:5.2.0'

.NET

Add the EventStore.Client.Grpc.Streams package to your project:

dotnet add package EventStore.Client.Grpc.Streams

Go

Install the esdb package using Go modules:

go get github.com/EventStore/EventStore-Client-Go/v3.2.0/esdb

Rust

No additional configuration is needed having Rust installed. Go check https://rustup.rs.

Connection string

Each SDK has its own way of configuring the client, but the connection string can always be used. The EventStoreDB connection string supports two schemas: esdb:// for connecting to a single-node server, and esdb+discover:// for connecting to a multi-node cluster. The difference between the two schemas is that when using esdb://, the client will connect directly to the node; with esdb+discover:// schema the client will use the gossip protocol to retrieve the cluster information and choose the right node to connect to. Since version 22.10, ESDB supports gossip on single-node deployments, so esdb+discover:// schema can be used for connecting to any topology.

The connection string has the following format:

esdb+discover://admin:changeit@cluster.dns.name:2113

There, cluster.dns.name is the name of a DNS A record that points to all the cluster nodes. Alternatively, you can list cluster nodes separated by comma instead of the cluster DNS name:

esdb+discover://admin:changeit@node1.dns.name:2113,node2.dns.name:2113,node3.dns.name:2113

There are a number of query parameters that can be used in the connection string to instruct the cluster how and where the connection should be established. All query parameters are optional.

When connecting to an insecure instance, specify tls=false parameter. For example, for a node running locally use esdb://localhost:2113?tls=false. Note that usernames and passwords aren't provided there because insecure deployments don't support authentication and authorisation.

Creating a client

First, create a client and get it connected to the database.

client = KurrentDBClient(
    uri="{connectionString}"
)

const client = KurrentDBClient.connectionString`{connectionString}`;

const client = KurrentDBClient.connectionString`{connectionString}`;

KurrentDBClientSettings settings = KurrentDBConnectionString.parseOrThrow("{connectionString}");
KurrentDBClient client = KurrentDBClient.create(settings);

const string connectionString = "esdb://admin:changeit@localhost:2113?tls=false&tlsVerifyCert=false";

var settings = EventStoreClientSettings.Create(connectionString);

var client = new EventStoreClient(settings);

settings, err := esdb.ParseConnectionString("{connectionString}")

if err != nil {
    panic(err)
}

db, err := esdb.NewClient(settings)

let settings = "{connectionString}".parse()?;
let client = Client::new(settings)?;

The client instance can be used as a singleton across the whole application. It doesn't need to open or close the connection.

Creating an event

You can write anything to EventStoreDB as events. The client needs a byte array as the event payload. Normally, you'd use a serialized object, and it's up to you to choose the serialization method.

The code snippet below creates an event object instance, serializes it, and adds it as a payload to the EventData structure, which the client can then write to the database.

new_event = NewEvent(
    id=uuid4(),
    type="TestEvent",
    data=b"I wrote my first event",
)

const event = jsonEvent({
  type: "TestEvent",
  data: {
    entityId: uuid(),
    importantData: "I wrote my first event!",
  },
});

type TestEvent = JSONEventType<
  "TestEvent",
  {
    entityId: string;
    importantData: string;
  }
>;

const event = jsonEvent<TestEvent>({
  type: "TestEvent",
  data: {
    entityId: uuid(),
    importantData: "I wrote my first event!",
  },
});

TestEvent event = new TestEvent();
JsonMapper jsonMapper = new JsonMapper();
event.setId(UUID.randomUUID().toString());
event.setImportantData("I wrote my first event!");

EventData eventData = EventData
        .builderAsJson("TestEvent", jsonMapper.writeValueAsBytes(event))
        .build();

var evt = new TestEvent {
    EntityId      = Guid.NewGuid().ToString("N"),
    ImportantData = "I wrote my first event!"
};

var eventData = new EventData(
    Uuid.NewUuid(),
    "TestEvent",
    JsonSerializer.SerializeToUtf8Bytes(evt)
);

testEvent := TestEvent{
    Id:            uuid.NewString(),
    ImportantData: "I wrote my first event!",
}

data, err := json.Marshal(testEvent)

if err != nil {
    panic(err)
}

eventData := esdb.EventData{
    ContentType: esdb.ContentTypeJson,
    EventType:   "TestEvent",
    Data:        data,
}

let event = TestEvent {
    id: Uuid::new_v4().to_string(),
    important_data: "I wrote my first event!".to_string(),
};

let event_data = EventData::json("TestEvent", &event)?.id(Uuid::new_v4());

Appending events

Each event in the database has its own unique identifier (UUID). The database uses it to ensure idempotent writes, but it only works if you specify the stream revision when appending events to the stream.

In the snippet below, we append the event to the stream some-stream.

client.append_to_stream(
    "some-stream",
    events=[new_event],
    current_version=StreamState.ANY,
)

await client.appendToStream(STREAM_NAME, event);

await client.appendToStream(STREAM_NAME, event);

client.appendToStream("some-stream", eventData)
        .get();

await client.AppendToStreamAsync(
    "some-stream",
    StreamState.Any,
    new[] { eventData },
    cancellationToken: cancellationToken
);

_, err = db.AppendToStream(context.Background(), "some-stream", esdb.AppendToStreamOptions{}, eventData)

client
    .append_to_stream("some-stream", &Default::default(), event_data)
    .await?;

Here we are appending events without checking if the stream exists or if the stream version matches the expected event version. See more advanced scenarios in appending events documentation.

Reading events

Finally, we can read events back from the some-stream stream.

events = client.get_stream("some-stream")

for event in events:
    # Doing something productive with the event
    print(event)

const events = client.readStream(STREAM_NAME, {
  direction: FORWARDS,
  fromRevision: START,
  maxCount: 10,
});

const events = client.readStream<TestEvent>(STREAM_NAME, {
  direction: FORWARDS,
  fromRevision: START,
  maxCount: 10,
});

ReadStreamOptions options = ReadStreamOptions.get()
        .forwards()
        .fromStart()
        .maxCount(10);

ReadResult result = client.readStream("some-stream", options)
        .get();

var result = client.ReadStreamAsync(
    Direction.Forwards,
    "some-stream",
    StreamPosition.Start,
    cancellationToken: cancellationToken
);

var events = await result.ToListAsync(cancellationToken);

stream, err := db.ReadStream(context.Background(), "some-stream", esdb.ReadStreamOptions{}, 10)

if err != nil {
    panic(err)
}

defer stream.Close()

for {
    event, err := stream.Recv()

    if errors.Is(err, io.EOF) {
        break
    }

    if err != nil {
        panic(err)
    }

    // Doing something productive with the event
    fmt.Println(event)
}

let options = ReadStreamOptions::default().max_count(10);
let mut stream = client.read_stream("some-stream", &options).await?;

while let Some(event) = stream.next().await? {
    // Doing something productive with the events.
}

When you read events from the stream, you get a collection of ResolvedEvent structures. The event payload is returned as a byte array and needs to be deserialized. See more advanced scenarios in reading events documentation.