Upsert Batch Pipeline Documents
client.Pipelines.Documents.Upsert(ctx, pipelineID, body) (*[]CloudDocument, error)
PUT/api/v1/pipelines/{pipeline_id}/documents
Upsert Batch Pipeline Documents
package main
import (
"context"
"fmt"
"github.com/stainless-sdks/llamacloud-prod-go"
"github.com/stainless-sdks/llamacloud-prod-go/option"
)
func main() {
client := llamacloudprod.NewClient(
option.WithAPIKey("My API Key"),
)
cloudDocuments, err := client.Pipelines.Documents.Upsert(
context.TODO(),
"182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e",
llamacloudprod.PipelineDocumentUpsertParams{
Body: []llamacloudprod.CloudDocumentCreateParam{llamacloudprod.CloudDocumentCreateParam{
Metadata: map[string]any{
"foo": "bar",
},
Text: "text",
}},
},
)
if err != nil {
panic(err.Error())
}
fmt.Printf("%+v\n", cloudDocuments)
}
[
{
"id": "id",
"metadata": {
"foo": "bar"
},
"text": "text",
"excluded_embed_metadata_keys": [
"string"
],
"excluded_llm_metadata_keys": [
"string"
],
"page_positions": [
0
],
"status_metadata": {
"foo": "bar"
}
}
]Returns Examples
[
{
"id": "id",
"metadata": {
"foo": "bar"
},
"text": "text",
"excluded_embed_metadata_keys": [
"string"
],
"excluded_llm_metadata_keys": [
"string"
],
"page_positions": [
0
],
"status_metadata": {
"foo": "bar"
}
}
]