Aiven for OpenSearch

from opensearchpy import OpenSearch
from datetime import datetime

# Create client
client = OpenSearch(
    hosts=['https://opensearch-service.aivencloud.com:12345'],
    http_auth=('avnadmin', 'your-password'),
    use_ssl=True,
    verify_certs=True,
    ssl_show_warn=False
)

# Create index
index_body = {
    'settings': {
        'index': {
            'number_of_shards': 2,
            'number_of_replicas': 1
        }
    },
    'mappings': {
        'properties': {
            'title': {'type': 'text'},
            'content': {'type': 'text'},
            'timestamp': {'type': 'date'}
        }
    }
}

client.indices.create(index='logs', body=index_body)

# Index a document
document = {
    'title': 'Application Error',
    'content': 'Connection timeout occurred',
    'timestamp': datetime.now(),
    'level': 'error',
    'service': 'api-gateway'
}

response = client.index(
    index='logs',
    body=document,
    refresh=True
)

print(f"Document indexed with ID: {response['_id']}")

# Search documents
search_body = {
    'query': {
        'bool': {
            'must': [
                {'match': {'content': 'timeout'}},
                {'term': {'level': 'error'}}
            ],
            'filter': [
                {'range': {'timestamp': {'gte': 'now-1h'}}}
            ]
        }
    },
    'sort': [{'timestamp': {'order': 'desc'}}],
    'size': 10
}

results = client.search(index='logs', body=search_body)

for hit in results['hits']['hits']:
    print(f"{hit['_source']['timestamp']}: {hit['_source']['title']}")

# Aggregation
agg_body = {
    'size': 0,
    'aggs': {
        'error_by_service': {
            'terms': {'field': 'service.keyword'},
            'aggs': {
                'recent_errors': {
                    'top_hits': {
                        'size': 1,
                        'sort': [{'timestamp': {'order': 'desc'}}]
                    }
                }
            }
        }
    }
}

agg_results = client.search(index='logs', body=agg_body)

const { Client } = require('@opensearch-project/opensearch');

const client = new Client({
  node: 'https://opensearch-service.aivencloud.com:12345',
  auth: {
    username: 'avnadmin',
    password: 'your-password'
  },
  ssl: {
    rejectUnauthorized: true
  }
});

async function main() {
  // Create index
  await client.indices.create({
    index: 'articles',
    body: {
      mappings: {
        properties: {
          title: { type: 'text' },
          content: { type: 'text' },
          author: { type: 'keyword' },
          published_at: { type: 'date' }
        }
      }
    }
  });

  // Index documents
  await client.index({
    index: 'articles',
    body: {
      title: 'Getting Started with OpenSearch',
      content: 'OpenSearch is a powerful search engine...',
      author: 'John Doe',
      published_at: new Date()
    },
    refresh: true
  });

  // Search
  const { body } = await client.search({
    index: 'articles',
    body: {
      query: {
        multi_match: {
          query: 'OpenSearch getting started',
          fields: ['title^2', 'content']
        }
      },
      highlight: {
        fields: {
          title: {},
          content: {}
        }
      }
    }
  });

  body.hits.hits.forEach(hit => {
    console.log(hit._source.title);
    if (hit.highlight) {
      console.log('Highlights:', hit.highlight);
    }
  });
}

main().catch(console.error);

import org.opensearch.client.opensearch.OpenSearchClient;
import org.opensearch.client.opensearch.core.*;
import org.opensearch.client.json.jackson.JacksonJsonpMapper;
import org.opensearch.client.transport.OpenSearchTransport;
import org.opensearch.client.transport.httpclient5.ApacheHttpClient5TransportBuilder;

public class OpenSearchExample {
    public static void main(String[] args) throws Exception {
        // Create client
        OpenSearchClient client = new OpenSearchClient(
            ApacheHttpClient5TransportBuilder
                .builder(HttpHost.create("https://opensearch-service.aivencloud.com:12345"))
                .setMapper(new JacksonJsonpMapper())
                .build()
        );

        // Index a document
        IndexRequest<Product> indexRequest = IndexRequest.of(i -> i
            .index("products")
            .document(new Product("Widget", 19.99, "electronics"))
        );

        IndexResponse response = client.index(indexRequest);
        System.out.println("Indexed document with ID: " + response.id());

        // Search
        SearchResponse<Product> searchResponse = client.search(s -> s
            .index("products")
            .query(q -> q
                .match(m -> m
                    .field("name")
                    .query("widget")
                )
            ),
            Product.class
        );

        searchResponse.hits().hits().forEach(hit -> {
            System.out.println("Found: " + hit.source().getName());
        });
    }
}