Sending Data to Opensearch

[Dashing-Nelson]

Hello,

I was looking through the document and couldn't find any document related to sending data into OpenSearch. I tried using AWS HTTP Request but it seems to be throwing a Forbidden error. I am using C++ for Lambda Function. Everything else is working fine.

std::shared_ptr<Aws::Http::HttpResponse> createDocument(nlohmann::json data, std::string id)
    {
        std::shared_ptr<Aws::IOStream> payload = Aws::MakeShared<Aws::StringStream>("s");
        *payload << data;
        std::string url = this->url + "/data_ingestion_log/_doc/" + id;
        if (Aws::Environment::GetEnv("STAGE") == "dev")
        {
            std::string url = this->url + "/data_ingestion_log_test/_doc/" + id;
        }
        std::shared_ptr<Aws::Http::HttpRequest> getRequest =
            CreateHttpRequest(url, Aws::Http::HttpMethod::HTTP_PUT,
                              Aws::Utils::Stream::DefaultResponseStreamFactoryMethod);
        getRequest->AddContentBody(payload);
        getRequest->CanonicalizeRequest();

        std::shared_ptr<Aws::Http::HttpClient>
            httpClient =
                Aws::Http::CreateHttpClient(config);
        std::shared_ptr<Aws::Http::HttpResponse> getResponse =
            httpClient->MakeRequest(getRequest);
        std::cout << getResponse->GetClientErrorMessage() << std::endl;
        std::stringstream ss;
        ss << getResponse->GetResponseBody().rdbuf();
        std::cout << ss.str() << std::endl;
        return getResponse;
    }

[jmklix]

You seam to be trying to build the request yourself, rather than using the sdk for this. Is there a specific reason that you are doing it this way?

edit: How to upload documents to OpenSearch

[Dashing-Nelson]

I couldn't find it in the SDK. Could you point it out? @jmklix

[jmklix]

This isn't supported by the sdk. You might have found this already, but here is some documentation on uploading documents to OpenSearch

[github-actions[bot]]

Hello! Reopening this discussion to make it searchable.