Skip to content

Commit

Permalink
Added guide for using raw JSON REST requests with low-level client.
Browse files Browse the repository at this point in the history
Signed-off-by: Djcarrillo6 <[email protected]>

Added sample for using raw JSON REST requests with low-level client.

Signed-off-by: Djcarrillo6 <[email protected]>
  • Loading branch information
Djcarrillo6 committed Oct 25, 2023
1 parent b014ff4 commit e4d1de2
Show file tree
Hide file tree
Showing 2 changed files with 98 additions and 0 deletions.
52 changes: 52 additions & 0 deletions guides/using-json-rest-requests.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,52 @@
- [Making Raw JSON REST Requests](#making-raw-json-rest-requests)
- [GET](#get)
- [PUT](#put)
- [POST](#post)
- [DELETE](#delete)

# Making Raw JSON REST Requests
OpenSearch exposes a REST API that you can use to interact with OpenSearch. The OpenSearch .NET client provides a low-level API that allows you to send raw JSON requests to OpenSearch. This API is useful if you want to use a feature that is not yet supported by the OpenSearch .NET client, but it supported by the OpenSearch REST API.

## GET
The following example returns the server version information via `GET /`.

```csharp
var versionResponse = await client.LowLevel.DoRequestAsync<DynamicResponse>(HttpMethod.GET, "/", new CancellationToken());
Console.WriteLine(versionResponse.Body["version"]["number"].ToString()); // Version number
```

## POST
The following example creates a document via `POST /movies/_doc` with a request body that specifies the document to create.

```csharp
var postResponse = await client.LowLevel.DoRequestAsync<DynamicResponse>(HttpMethod.POST, "/movies/_doc", new CancellationToken(), PostData.Serializable(
new
{
title = "The Dark Knight 6",
director = "Christopher Nolan",
year = 2012
}));
Console.WriteLine(postResponse.Body["result"].ToString()); // created
```

# PUT
The following example creates a document via `PUT /movies/_doc/{id}` with a request body that specifies the document to create.

```csharp
var putResponse = await client.LowLevel.DoRequestAsync<DynamicResponse>(HttpMethod.PUT, "/movies/_doc/1", new CancellationToken(), PostData.Serializable(
new
{
title = "The Dark Knight 6",
director = "Christopher Nolan",
year = 2023
}));
Console.WriteLine(putResponse.Body["result"].ToString()); // created
```

# DELETE
The following example deletes a document via `DELETE /movies/_doc/{id}`.

```csharp
var deleteResponse = await client.LowLevel.DoRequestAsync<DynamicResponse>(HttpMethod.DELETE, "/movies/_doc/1", new CancellationToken());
Console.WriteLine(deleteResponse.Body["result"].ToString()); // deleted
```
46 changes: 46 additions & 0 deletions samples/UsingJsonRestRequestsSample.cs
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
using OpenSearch.Client;
using OpenSearch.Net;
using HttpMethod = OpenSearch.Net.HttpMethod;


class Program
{
static async Task Main(string[] args)
{
var node = new Uri("https://localhost:9200");
var config = new ConnectionSettings(node)
.ServerCertificateValidationCallback(CertificateValidations.AllowAll)
.BasicAuthentication("admin", "admin")
.DisableDirectStreaming();

var client = new OpenSearchClient(config);

// GET
var versionResponse = await client.LowLevel.DoRequestAsync<DynamicResponse>(HttpMethod.GET, "/", new CancellationToken());
Console.WriteLine(versionResponse.Body["version"]["number"].ToString()); // Version number

// Post
var postResponse = await client.LowLevel.DoRequestAsync<DynamicResponse>(HttpMethod.POST, "/movies/_doc", new CancellationToken(), PostData.Serializable(
new
{
title = "The Dark Knight",
director = "Christopher Nolan",
year = 2012
}));
Console.WriteLine(postResponse.Body["result"].ToString()); // created

// PUT
var putResponse = await client.LowLevel.DoRequestAsync<DynamicResponse>(HttpMethod.PUT, "/movies/_doc/1", new CancellationToken(), PostData.Serializable(
new
{
title = "The Dark Knight 2",
director = "Christopher Nolan",
year = 2012
}));
Console.WriteLine(putResponse.Body["result"].ToString()); // created

// DELETE
var deleteResponse = await client.LowLevel.DoRequestAsync<DynamicResponse>(HttpMethod.DELETE, "/movies/_doc/1", new CancellationToken());
Console.WriteLine(deleteResponse.Body["result"].ToString()); // deleted
}
}

0 comments on commit e4d1de2

Please sign in to comment.