From 6d9b04a8f9881228a09ffb7f12bec61546f09acd Mon Sep 17 00:00:00 2001 From: speakeasybot Date: Wed, 17 Dec 2025 00:12:30 +0000 Subject: [PATCH] ## Python SDK Changes: * `unstructured_client.destinations.create_destination()`: * `request.create_destination_connector.config.[open_search_connector_config_input]` **Added** * `response.config.[open_search_connector_config]` **Added** * `unstructured_client.destinations.get_destination()`: `response.config.[open_search_connector_config]` **Added** * `unstructured_client.destinations.list_destinations()`: * `request.destination_type` **Changed** * `response.[].config.[open_search_connector_config]` **Added** * `unstructured_client.destinations.update_destination()`: * `request.update_destination_connector.config.[open_search_connector_config_input]` **Added** * `response.config.[open_search_connector_config]` **Added** * `unstructured_client.sources.create_source()`: * `request.create_source_connector.config.[open_search_connector_config_input]` **Added** * `response.config.[open_search_connector_config]` **Added** * `unstructured_client.sources.get_source()`: `response.config.[open_search_connector_config]` **Added** * `unstructured_client.sources.list_sources()`: * `request.source_type` **Changed** * `response.[].config.[open_search_connector_config]` **Added** * `unstructured_client.sources.update_source()`: * `request.update_source_connector.config.[open_search_connector_config_input]` **Added** * `response.config.[open_search_connector_config]` **Added** --- .speakeasy/gen.lock | 52 +++++--- .speakeasy/workflow.lock | 12 +- RELEASES.md | 12 +- codeSamples.yaml | 6 +- docs/models/shared/config.md | 6 + .../shared/createsourceconnectorconfig.md | 6 + .../destinationconnectorinformationconfig.md | 6 + .../models/shared/destinationconnectortype.md | 1 + .../shared/opensearchconnectorconfig.md | 25 ++++ .../shared/opensearchconnectorconfiginput.md | 17 +++ .../sourceconnectorinformationconfig.md | 6 + docs/models/shared/sourceconnectortype.md | 1 + .../updatedestinationconnectorconfig.md | 6 + .../shared/updatesourceconnectorconfig.md | 6 + gen.yaml | 2 +- pyproject.toml | 4 +- src/unstructured_client/_version.py | 4 +- .../models/shared/__init__.py | 16 +++ .../shared/createdestinationconnector.py | 22 ++-- .../models/shared/createsourceconnector.py | 26 ++-- .../shared/destinationconnectorinformation.py | 34 +++-- .../models/shared/destinationconnectortype.py | 1 + .../shared/opensearchconnectorconfig.py | 124 ++++++++++++++++++ .../shared/opensearchconnectorconfiginput.py | 106 +++++++++++++++ .../shared/sourceconnectorinformation.py | 18 ++- .../models/shared/sourceconnectortype.py | 1 + .../shared/updatedestinationconnector.py | 22 ++-- .../models/shared/updatesourceconnector.py | 26 ++-- 28 files changed, 477 insertions(+), 91 deletions(-) create mode 100644 docs/models/shared/opensearchconnectorconfig.md create mode 100644 docs/models/shared/opensearchconnectorconfiginput.md create mode 100644 src/unstructured_client/models/shared/opensearchconnectorconfig.py create mode 100644 src/unstructured_client/models/shared/opensearchconnectorconfiginput.py diff --git a/.speakeasy/gen.lock b/.speakeasy/gen.lock index 0a645122..1198529a 100755 --- a/.speakeasy/gen.lock +++ b/.speakeasy/gen.lock @@ -1,12 +1,12 @@ lockVersion: 2.0.0 id: 8b5fa338-9106-4734-abf0-e30d67044a90 management: - docChecksum: e741a96121ddff12793a36dd5e2258f4 + docChecksum: 9573da525ab969618fc37288c7baec6a docVersion: 1.2.23 speakeasyVersion: 1.601.0 generationVersion: 2.680.0 - releaseVersion: 0.42.5 - configChecksum: 3b3b92259de5fc0033e3f01348631e31 + releaseVersion: 0.42.6 + configChecksum: 234c791d16e1b5f3af5d003964b292f6 repoURL: https://github.com/Unstructured-IO/unstructured-python-client.git repoSubDirectory: . installationURL: https://github.com/Unstructured-IO/unstructured-python-client.git @@ -180,6 +180,8 @@ generatedFiles: - docs/models/shared/onedrivedestinationconnectorconfiginput.md - docs/models/shared/onedrivesourceconnectorconfig.md - docs/models/shared/onedrivesourceconnectorconfiginput.md + - docs/models/shared/opensearchconnectorconfig.md + - docs/models/shared/opensearchconnectorconfiginput.md - docs/models/shared/outlooksourceconnectorconfig.md - docs/models/shared/outlooksourceconnectorconfiginput.md - docs/models/shared/outputformat.md @@ -368,6 +370,8 @@ generatedFiles: - src/unstructured_client/models/shared/onedrivedestinationconnectorconfiginput.py - src/unstructured_client/models/shared/onedrivesourceconnectorconfig.py - src/unstructured_client/models/shared/onedrivesourceconnectorconfiginput.py + - src/unstructured_client/models/shared/opensearchconnectorconfig.py + - src/unstructured_client/models/shared/opensearchconnectorconfiginput.py - src/unstructured_client/models/shared/outlooksourceconnectorconfig.py - src/unstructured_client/models/shared/outlooksourceconnectorconfiginput.py - src/unstructured_client/models/shared/partition_parameters.py @@ -921,7 +925,7 @@ trackedFiles: docs/models/shared/boxsourceconnectorconfiginput.md: last_write_checksum: sha1:e75625a2d8e1092d752dec9d6416ca2dc7ece940 docs/models/shared/config.md: - last_write_checksum: sha1:9b8db306af8207882a98a06397fb1df25514a5d5 + last_write_checksum: sha1:921b555dc3b2f4c796f265958e1e497bc2c2c221 docs/models/shared/confluencesourceconnectorconfig.md: last_write_checksum: sha1:f0fc3f07b8dfe0af11928df4f8246168500ec3bb docs/models/shared/confluencesourceconnectorconfiginput.md: @@ -941,7 +945,7 @@ trackedFiles: docs/models/shared/createsourceconnector.md: last_write_checksum: sha1:006ad810becfd9f2d7c8e8ff5de3cb0d0815bf72 docs/models/shared/createsourceconnectorconfig.md: - last_write_checksum: sha1:29acb21f56b4ddfa16c67240522411fda161afdc + last_write_checksum: sha1:8021615bdecc4203ff24a7663bc51928687771fc docs/models/shared/createworkflow.md: last_write_checksum: sha1:8aaf8738ef81e5c333b21e0052015755d21fdb1a docs/models/shared/crontabentry.md: @@ -963,9 +967,9 @@ trackedFiles: docs/models/shared/destinationconnectorinformation.md: last_write_checksum: sha1:3ee4e344b304ba428401ae1c74f1aa5bcdc556da docs/models/shared/destinationconnectorinformationconfig.md: - last_write_checksum: sha1:52df1d0ee4ad0ec7cfd1698b5a72f39a93f00806 + last_write_checksum: sha1:a2d78a4773c889d1e189a8f6f31e2a1e234a0b19 docs/models/shared/destinationconnectortype.md: - last_write_checksum: sha1:3b405c8485530eb259e1607d89af14cf94922526 + last_write_checksum: sha1:85ba31b2dfb9d633b795ba98eb58304bdbd1fef5 docs/models/shared/dropboxsourceconnectorconfig.md: last_write_checksum: sha1:dd236db60bdbbda1422cc81ec574fe9f3f7f4ce3 docs/models/shared/dropboxsourceconnectorconfiginput.md: @@ -1048,6 +1052,10 @@ trackedFiles: last_write_checksum: sha1:d0cc7e551dc0509a6f04cd42f2ab3ef58c41dfc7 docs/models/shared/onedrivesourceconnectorconfiginput.md: last_write_checksum: sha1:415b2ce792db84e2404226b87091d3051e0bea50 + docs/models/shared/opensearchconnectorconfig.md: + last_write_checksum: sha1:4978902a082f133162d847258b8ac1948acede2e + docs/models/shared/opensearchconnectorconfiginput.md: + last_write_checksum: sha1:448a11697dd2c4e1cc8c131fb7e7b3f39dc762b5 docs/models/shared/outlooksourceconnectorconfig.md: last_write_checksum: sha1:2094d7b13d7ee1d4b8b1f93442b68fd4156b13bc docs/models/shared/outlooksourceconnectorconfiginput.md: @@ -1113,9 +1121,9 @@ trackedFiles: docs/models/shared/sourceconnectorinformation.md: last_write_checksum: sha1:635fbe720ba6de5d875a2ae26a18aba49c118353 docs/models/shared/sourceconnectorinformationconfig.md: - last_write_checksum: sha1:0263a9f5b6dbc4ef0e07a15239e236be66b5750c + last_write_checksum: sha1:9de17090c726544aacd1844e86a4f8336174a12f docs/models/shared/sourceconnectortype.md: - last_write_checksum: sha1:1ed56b342903fec2a5c4e6fa8ee843810a90d149 + last_write_checksum: sha1:a9a430ea130db8da8fc88af4039e411a680684d7 docs/models/shared/strategy.md: last_write_checksum: sha1:07155e281d43ece3d6970b315ca1761ea18cce9f docs/models/shared/templatedetail.md: @@ -1127,11 +1135,11 @@ trackedFiles: docs/models/shared/updatedestinationconnector.md: last_write_checksum: sha1:37c58c6b362551502eabf5eca98e99575d642677 docs/models/shared/updatedestinationconnectorconfig.md: - last_write_checksum: sha1:9ec4cfd55e52c4f03e99a7154172b22e26af83ba + last_write_checksum: sha1:8b87feb4b95b89e93685f7817cb97396a4537d0f docs/models/shared/updatesourceconnector.md: last_write_checksum: sha1:c13569bb40dcaee8f13e077eb5b53d95098ea34d docs/models/shared/updatesourceconnectorconfig.md: - last_write_checksum: sha1:c110194e464b7c3c530dc0d768c8747f1474755b + last_write_checksum: sha1:33c4d78aa6733a8151b0a8b7558e8b018cd59307 docs/models/shared/updateworkflow.md: last_write_checksum: sha1:94e95e0b8746baf81b33fab234ee5d320a3fae2e docs/models/shared/updateworkflowschedule.md: @@ -1283,7 +1291,7 @@ trackedFiles: src/unstructured_client/models/operations/update_workflow.py: last_write_checksum: sha1:2987bcb5781b5002aa307e5255c7072f92b026a6 src/unstructured_client/models/shared/__init__.py: - last_write_checksum: sha1:84789d683d1f00f60dcf41e302d0812b7a72e2c7 + last_write_checksum: sha1:c2ad5956b789b46b0f2f4d630d11171cd4da7550 src/unstructured_client/models/shared/astradbconnectorconfig.py: last_write_checksum: sha1:c9ada225d014655e2800c4dac8dcb95282a12cbc src/unstructured_client/models/shared/astradbconnectorconfiginput.py: @@ -1323,9 +1331,9 @@ trackedFiles: src/unstructured_client/models/shared/couchbasesourceconnectorconfiginput.py: last_write_checksum: sha1:87a98b17a3b14b9defe1b018e4c98a1d9aeea73b src/unstructured_client/models/shared/createdestinationconnector.py: - last_write_checksum: sha1:1c60a323f80a24edeec45c4cbc15c85432cc3c6c + last_write_checksum: sha1:7137800f627ef8537e996ac9cb1d9161cc9eb187 src/unstructured_client/models/shared/createsourceconnector.py: - last_write_checksum: sha1:a2436029be0bfe9533c607b1ed3f26d310d0e522 + last_write_checksum: sha1:1a469c646e895744b33b804502330f3c543aae3d src/unstructured_client/models/shared/createworkflow.py: last_write_checksum: sha1:9201d99f3a9ee2d561b68b68d2af487ee9e21f9d src/unstructured_client/models/shared/crontabentry.py: @@ -1345,9 +1353,9 @@ trackedFiles: src/unstructured_client/models/shared/deltatableconnectorconfiginput.py: last_write_checksum: sha1:42ebe9712bc0f083b890cd7ff78208d9e838dfb8 src/unstructured_client/models/shared/destinationconnectorinformation.py: - last_write_checksum: sha1:36455d4144c5de6a6ca78078006679ced5cc0a6e + last_write_checksum: sha1:80bbf3b4fd6f477fe0b2deec328716aeb9054ee3 src/unstructured_client/models/shared/destinationconnectortype.py: - last_write_checksum: sha1:00ec603c427b636ae82d8a688f5383534e12ab69 + last_write_checksum: sha1:8a535b852261fe20bcdcd5e7ebfc07524270b934 src/unstructured_client/models/shared/dropboxsourceconnectorconfig.py: last_write_checksum: sha1:975b665d4a1280a04558b963d7564dafaa04afc1 src/unstructured_client/models/shared/dropboxsourceconnectorconfiginput.py: @@ -1422,6 +1430,10 @@ trackedFiles: last_write_checksum: sha1:af9f70cc946dd96d58b1164344b0f5682490cce2 src/unstructured_client/models/shared/onedrivesourceconnectorconfiginput.py: last_write_checksum: sha1:50f983e8f78b96d8523ea0c0df7e65f560cb6ea0 + src/unstructured_client/models/shared/opensearchconnectorconfig.py: + last_write_checksum: sha1:7f073c0d825d8506d066e78365db325ac5df6fbd + src/unstructured_client/models/shared/opensearchconnectorconfiginput.py: + last_write_checksum: sha1:c8bf14e800fac4e048179b623443043079036d27 src/unstructured_client/models/shared/outlooksourceconnectorconfig.py: last_write_checksum: sha1:e414684ad984614ea53f18d3525c35ac023e3b62 src/unstructured_client/models/shared/outlooksourceconnectorconfiginput.py: @@ -1479,9 +1491,9 @@ trackedFiles: src/unstructured_client/models/shared/sortdirection.py: last_write_checksum: sha1:316a46717625825ea3a622089df62f1c02be1482 src/unstructured_client/models/shared/sourceconnectorinformation.py: - last_write_checksum: sha1:699d383ccaee500ea027e4bd277af43e614b9b24 + last_write_checksum: sha1:e704ff822aef603f14d1b243962d177d210982fb src/unstructured_client/models/shared/sourceconnectortype.py: - last_write_checksum: sha1:7c7ae7a8453ad266f3da93be17eddc48be119807 + last_write_checksum: sha1:cc3f9e479b10403211055f781aec66a5a918a169 src/unstructured_client/models/shared/templatedetail.py: last_write_checksum: sha1:05292e12a45407c2cb6c500386f2d28298e2129f src/unstructured_client/models/shared/templatelistitem.py: @@ -1489,9 +1501,9 @@ trackedFiles: src/unstructured_client/models/shared/templatenode.py: last_write_checksum: sha1:e4eb4fda54c7f177addc32f786a59cdaf886ea1d src/unstructured_client/models/shared/updatedestinationconnector.py: - last_write_checksum: sha1:ac3328aa63eabc4d83f993fc7532cf99f141dff8 + last_write_checksum: sha1:f3a359c44d4e54ca85c7c69ac087726094d06655 src/unstructured_client/models/shared/updatesourceconnector.py: - last_write_checksum: sha1:25577dad79e9eca6b8930bf390eb8c5ab94fecc6 + last_write_checksum: sha1:66a29ca6427816cdb1846d63e3d466296dbd3abb src/unstructured_client/models/shared/updateworkflow.py: last_write_checksum: sha1:f14b03dfc4d74915d60369f07f17dd6805820cc0 src/unstructured_client/models/shared/validationerror.py: diff --git a/.speakeasy/workflow.lock b/.speakeasy/workflow.lock index ebb5cdc3..5cc998d5 100644 --- a/.speakeasy/workflow.lock +++ b/.speakeasy/workflow.lock @@ -2,20 +2,20 @@ speakeasyVersion: 1.601.0 sources: my-source: sourceNamespace: my-source - sourceRevisionDigest: sha256:f678ba24b97d66fb952504f32632687a733de3b78cbbabbcc94f05bd2518760f - sourceBlobDigest: sha256:a05d5043ae1f3f3b9efdffd41aaa99a59de5c9efde44b1fb3b8ce8b8f9711f31 + sourceRevisionDigest: sha256:0f9a0b853a66a4d2c4182cacb93654d9f492306057400aa3b8f8f97d256897d7 + sourceBlobDigest: sha256:cbdac97fc0b581bed2dfc066cc8b34726833f40a7d12c68ca7c72c5dc8ad85f7 tags: - latest - - speakeasy-sdk-regen-1765907791 + - speakeasy-sdk-regen-1765930243 - 1.2.23 targets: unstructured-python: source: my-source sourceNamespace: my-source - sourceRevisionDigest: sha256:f678ba24b97d66fb952504f32632687a733de3b78cbbabbcc94f05bd2518760f - sourceBlobDigest: sha256:a05d5043ae1f3f3b9efdffd41aaa99a59de5c9efde44b1fb3b8ce8b8f9711f31 + sourceRevisionDigest: sha256:0f9a0b853a66a4d2c4182cacb93654d9f492306057400aa3b8f8f97d256897d7 + sourceBlobDigest: sha256:cbdac97fc0b581bed2dfc066cc8b34726833f40a7d12c68ca7c72c5dc8ad85f7 codeSamplesNamespace: my-source-code-samples - codeSamplesRevisionDigest: sha256:ba3cf768e47791ee0767b02702cbe524c083b17eadfde982ddb7418695ecd375 + codeSamplesRevisionDigest: sha256:5ac8349c260229dbee869bfd0e1add6e7ba61a267c0f398288ac809271c67fee workflow: workflowVersion: 1.0.0 speakeasyVersion: latest diff --git a/RELEASES.md b/RELEASES.md index be1a6c07..1d9fbef3 100644 --- a/RELEASES.md +++ b/RELEASES.md @@ -1150,4 +1150,14 @@ Based on: ### Generated - [python v0.42.5] . ### Releases -- [PyPI v0.42.5] https://pypi.org/project/unstructured-client/0.42.5 - . \ No newline at end of file +- [PyPI v0.42.5] https://pypi.org/project/unstructured-client/0.42.5 - . + +## 2025-12-17 00:10:26 +### Changes +Based on: +- OpenAPI Doc +- Speakeasy CLI 1.601.0 (2.680.0) https://github.com/speakeasy-api/speakeasy +### Generated +- [python v0.42.6] . +### Releases +- [PyPI v0.42.6] https://pypi.org/project/unstructured-client/0.42.6 - . \ No newline at end of file diff --git a/codeSamples.yaml b/codeSamples.yaml index b903ad06..33e7cc44 100644 --- a/codeSamples.yaml +++ b/codeSamples.yaml @@ -14,7 +14,7 @@ actions: "x-codeSamples": - "lang": "python" "label": "create_destination" - "source": "from unstructured_client import UnstructuredClient\nfrom unstructured_client.models import shared\n\n\nwith UnstructuredClient() as uc_client:\n\n res = uc_client.destinations.create_destination(request={\n \"create_destination_connector\": {\n \"name\": \"\",\n \"type\": shared.DestinationConnectorType.MONGODB,\n \"config\": {\n \"index_name\": \"\",\n \"api_key\": \"\",\n \"namespace\": \"\",\n \"batch_size\": 50,\n },\n },\n })\n\n assert res.destination_connector_information is not None\n\n # Handle response\n print(res.destination_connector_information)" + "source": "from unstructured_client import UnstructuredClient\nfrom unstructured_client.models import shared\n\n\nwith UnstructuredClient() as uc_client:\n\n res = uc_client.destinations.create_destination(request={\n \"create_destination_connector\": {\n \"name\": \"\",\n \"type\": shared.DestinationConnectorType.MOTHERDUCK,\n \"config\": {\n \"hosts\": [],\n \"index_name\": \"\",\n },\n },\n })\n\n assert res.destination_connector_information is not None\n\n # Handle response\n print(res.destination_connector_information)" - target: $["paths"]["/api/v1/destinations/{destination_id}"]["delete"] update: "x-codeSamples": @@ -32,7 +32,7 @@ actions: "x-codeSamples": - "lang": "python" "label": "update_destination" - "source": "from unstructured_client import UnstructuredClient\n\n\nwith UnstructuredClient() as uc_client:\n\n res = uc_client.destinations.update_destination(request={\n \"destination_id\": \"962d9d1e-f847-487c-a731-3d18392716fb\",\n \"update_destination_connector\": {\n \"config\": {\n \"remote_url\": \"https://lined-clamp.info\",\n \"service_account_key\": \"\",\n },\n },\n })\n\n assert res.destination_connector_information is not None\n\n # Handle response\n print(res.destination_connector_information)" + "source": "from unstructured_client import UnstructuredClient\n\n\nwith UnstructuredClient() as uc_client:\n\n res = uc_client.destinations.update_destination(request={\n \"destination_id\": \"9726962d-9d1e-4f84-8787-c7313d183927\",\n \"update_destination_connector\": {\n \"config\": {\n \"bootstrap_servers\": \"\",\n \"port\": 9092,\n \"topic\": \"\",\n \"kafka_api_key\": \"\",\n \"secret\": \"\",\n \"batch_size\": 100,\n },\n },\n })\n\n assert res.destination_connector_information is not None\n\n # Handle response\n print(res.destination_connector_information)" - target: $["paths"]["/api/v1/destinations/{destination_id}/connection-check"]["get"] update: "x-codeSamples": @@ -98,7 +98,7 @@ actions: "x-codeSamples": - "lang": "python" "label": "create_source" - "source": "from unstructured_client import UnstructuredClient\nfrom unstructured_client.models import shared\n\n\nwith UnstructuredClient() as uc_client:\n\n res = uc_client.sources.create_source(request={\n \"create_source_connector\": {\n \"name\": \"\",\n \"type\": shared.SourceConnectorType.DROPBOX,\n \"config\": {\n \"remote_url\": \"https://ugly-ribbon.info\",\n \"recursive\": True,\n },\n },\n })\n\n assert res.source_connector_information is not None\n\n # Handle response\n print(res.source_connector_information)" + "source": "from unstructured_client import UnstructuredClient\nfrom unstructured_client.models import shared\n\n\nwith UnstructuredClient() as uc_client:\n\n res = uc_client.sources.create_source(request={\n \"create_source_connector\": {\n \"name\": \"\",\n \"type\": shared.SourceConnectorType.DROPBOX,\n \"config\": {\n \"box_app_config\": \"\",\n \"remote_url\": \"https://ugly-ribbon.info\",\n \"recursive\": True,\n },\n },\n })\n\n assert res.source_connector_information is not None\n\n # Handle response\n print(res.source_connector_information)" - target: $["paths"]["/api/v1/sources/{source_id}"]["delete"] update: "x-codeSamples": diff --git a/docs/models/shared/config.md b/docs/models/shared/config.md index b6441eb9..7e3a09c7 100644 --- a/docs/models/shared/config.md +++ b/docs/models/shared/config.md @@ -87,6 +87,12 @@ value: shared.Neo4jDestinationConnectorConfigInput = /* values here */ value: shared.OneDriveDestinationConnectorConfigInput = /* values here */ ``` +### `shared.OpenSearchConnectorConfigInput` + +```python +value: shared.OpenSearchConnectorConfigInput = /* values here */ +``` + ### `shared.PineconeDestinationConnectorConfigInput` ```python diff --git a/docs/models/shared/createsourceconnectorconfig.md b/docs/models/shared/createsourceconnectorconfig.md index fb27febf..c4965b66 100644 --- a/docs/models/shared/createsourceconnectorconfig.md +++ b/docs/models/shared/createsourceconnectorconfig.md @@ -75,6 +75,12 @@ value: shared.MongoDBConnectorConfigInput = /* values here */ value: shared.OneDriveSourceConnectorConfigInput = /* values here */ ``` +### `shared.OpenSearchConnectorConfigInput` + +```python +value: shared.OpenSearchConnectorConfigInput = /* values here */ +``` + ### `shared.OutlookSourceConnectorConfigInput` ```python diff --git a/docs/models/shared/destinationconnectorinformationconfig.md b/docs/models/shared/destinationconnectorinformationconfig.md index 70b163e8..45e3cf24 100644 --- a/docs/models/shared/destinationconnectorinformationconfig.md +++ b/docs/models/shared/destinationconnectorinformationconfig.md @@ -87,6 +87,12 @@ value: shared.Neo4jDestinationConnectorConfig = /* values here */ value: shared.OneDriveDestinationConnectorConfig = /* values here */ ``` +### `shared.OpenSearchConnectorConfig` + +```python +value: shared.OpenSearchConnectorConfig = /* values here */ +``` + ### `shared.PineconeDestinationConnectorConfig` ```python diff --git a/docs/models/shared/destinationconnectortype.md b/docs/models/shared/destinationconnectortype.md index 02159f7f..9c6893ac 100644 --- a/docs/models/shared/destinationconnectortype.md +++ b/docs/models/shared/destinationconnectortype.md @@ -20,6 +20,7 @@ | `MOTHERDUCK` | motherduck | | `NEO4J` | neo4j | | `ONEDRIVE` | onedrive | +| `OPENSEARCH` | opensearch | | `PINECONE` | pinecone | | `POSTGRES` | postgres | | `REDIS` | redis | diff --git a/docs/models/shared/opensearchconnectorconfig.md b/docs/models/shared/opensearchconnectorconfig.md new file mode 100644 index 00000000..e444f839 --- /dev/null +++ b/docs/models/shared/opensearchconnectorconfig.md @@ -0,0 +1,25 @@ +# OpenSearchConnectorConfig + +OpenSearch connector configuration. + +OpenSearch is a fork of Elasticsearch with similar functionality. +Supports two authentication methods: +1. Basic auth: username + password +2. AWS IAM auth: aws_access_key_id + aws_secret_access_key (+ optional aws_session_token) + +For AWS OpenSearch Service or OpenSearch Serverless, region and service type +are auto-detected from the host URL. + + +## Fields + +| Field | Type | Required | Description | +| -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | +| `aws_access_key_id` | *OptionalNullable[str]* | :heavy_minus_sign: | AWS access key ID for IAM authentication. When provided with aws_secret_access_key, IAM authentication is used instead of basic auth. Region and service type are auto-detected from the host URL. | +| `aws_secret_access_key` | *OptionalNullable[str]* | :heavy_minus_sign: | AWS secret access key for IAM authentication. Required when aws_access_key_id is provided. | +| `aws_session_token` | *OptionalNullable[str]* | :heavy_minus_sign: | AWS session token for temporary credentials (optional). Only used when aws_access_key_id and aws_secret_access_key are provided. | +| `hosts` | List[*str*] | :heavy_check_mark: | List of OpenSearch hosts to connect to | +| `index_name` | *str* | :heavy_check_mark: | Name of the OpenSearch index to read from or write to | +| `password` | *OptionalNullable[str]* | :heavy_minus_sign: | Password for basic authentication | +| `use_ssl` | *OptionalNullable[bool]* | :heavy_minus_sign: | Whether to use SSL for the connection | +| `username` | *OptionalNullable[str]* | :heavy_minus_sign: | Username for basic authentication | \ No newline at end of file diff --git a/docs/models/shared/opensearchconnectorconfiginput.md b/docs/models/shared/opensearchconnectorconfiginput.md new file mode 100644 index 00000000..5e063c4b --- /dev/null +++ b/docs/models/shared/opensearchconnectorconfiginput.md @@ -0,0 +1,17 @@ +# OpenSearchConnectorConfigInput + +Input model for creating/updating OpenSearch connectors via API. + + +## Fields + +| Field | Type | Required | Description | +| -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | +| `aws_access_key_id` | *OptionalNullable[str]* | :heavy_minus_sign: | AWS access key ID for IAM authentication. When provided with aws_secret_access_key, IAM authentication is used instead of basic auth. Region and service type are auto-detected from the host URL. | +| `aws_secret_access_key` | *OptionalNullable[str]* | :heavy_minus_sign: | AWS secret access key for IAM authentication. Required when aws_access_key_id is provided. | +| `aws_session_token` | *OptionalNullable[str]* | :heavy_minus_sign: | AWS session token for temporary credentials (optional). Only used when aws_access_key_id and aws_secret_access_key are provided. | +| `hosts` | List[*str*] | :heavy_check_mark: | List of OpenSearch hosts to connect to | +| `index_name` | *str* | :heavy_check_mark: | Name of the OpenSearch index to read from or write to | +| `password` | *OptionalNullable[str]* | :heavy_minus_sign: | Password for basic authentication | +| `use_ssl` | *OptionalNullable[bool]* | :heavy_minus_sign: | Whether to use SSL for the connection | +| `username` | *OptionalNullable[str]* | :heavy_minus_sign: | Username for basic authentication | \ No newline at end of file diff --git a/docs/models/shared/sourceconnectorinformationconfig.md b/docs/models/shared/sourceconnectorinformationconfig.md index b0b59b98..e5454919 100644 --- a/docs/models/shared/sourceconnectorinformationconfig.md +++ b/docs/models/shared/sourceconnectorinformationconfig.md @@ -75,6 +75,12 @@ value: shared.MongoDBConnectorConfig = /* values here */ value: shared.OneDriveSourceConnectorConfig = /* values here */ ``` +### `shared.OpenSearchConnectorConfig` + +```python +value: shared.OpenSearchConnectorConfig = /* values here */ +``` + ### `shared.OutlookSourceConnectorConfig` ```python diff --git a/docs/models/shared/sourceconnectortype.md b/docs/models/shared/sourceconnectortype.md index 059c0233..e5c4b636 100644 --- a/docs/models/shared/sourceconnectortype.md +++ b/docs/models/shared/sourceconnectortype.md @@ -17,6 +17,7 @@ | `KAFKA_CLOUD` | kafka-cloud | | `MONGODB` | mongodb | | `ONEDRIVE` | onedrive | +| `OPENSEARCH` | opensearch | | `OUTLOOK` | outlook | | `POSTGRES` | postgres | | `S3` | s3 | diff --git a/docs/models/shared/updatedestinationconnectorconfig.md b/docs/models/shared/updatedestinationconnectorconfig.md index ea3688cb..1ec8f735 100644 --- a/docs/models/shared/updatedestinationconnectorconfig.md +++ b/docs/models/shared/updatedestinationconnectorconfig.md @@ -87,6 +87,12 @@ value: shared.Neo4jDestinationConnectorConfigInput = /* values here */ value: shared.OneDriveDestinationConnectorConfigInput = /* values here */ ``` +### `shared.OpenSearchConnectorConfigInput` + +```python +value: shared.OpenSearchConnectorConfigInput = /* values here */ +``` + ### `shared.PineconeDestinationConnectorConfigInput` ```python diff --git a/docs/models/shared/updatesourceconnectorconfig.md b/docs/models/shared/updatesourceconnectorconfig.md index 3e42ad47..e917cc98 100644 --- a/docs/models/shared/updatesourceconnectorconfig.md +++ b/docs/models/shared/updatesourceconnectorconfig.md @@ -75,6 +75,12 @@ value: shared.MongoDBConnectorConfigInput = /* values here */ value: shared.OneDriveSourceConnectorConfigInput = /* values here */ ``` +### `shared.OpenSearchConnectorConfigInput` + +```python +value: shared.OpenSearchConnectorConfigInput = /* values here */ +``` + ### `shared.OutlookSourceConnectorConfigInput` ```python diff --git a/gen.yaml b/gen.yaml index 1e0e0b8e..8e8adc94 100644 --- a/gen.yaml +++ b/gen.yaml @@ -22,7 +22,7 @@ generation: schemas: allOfMergeStrategy: shallowMerge python: - version: 0.42.5 + version: 0.42.6 additionalDependencies: dev: deepdiff: '>=6.0' diff --git a/pyproject.toml b/pyproject.toml index e03df679..d4d21457 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,10 +1,10 @@ [project] name = "unstructured-client" -version = "0.42.5" +version = "0.42.6" description = "Python Client SDK for Unstructured API" authors = [{ name = "Unstructured" },] -readme = "README.md" +readme = "README-PYPI.md" requires-python = ">=3.9.2" dependencies = [ "aiofiles >=24.1.0", diff --git a/src/unstructured_client/_version.py b/src/unstructured_client/_version.py index 64163fad..711aa0af 100644 --- a/src/unstructured_client/_version.py +++ b/src/unstructured_client/_version.py @@ -3,10 +3,10 @@ import importlib.metadata __title__: str = "unstructured-client" -__version__: str = "0.42.5" +__version__: str = "0.42.6" __openapi_doc_version__: str = "1.2.23" __gen_version__: str = "2.680.0" -__user_agent__: str = "speakeasy-sdk/python 0.42.5 2.680.0 1.2.23 unstructured-client" +__user_agent__: str = "speakeasy-sdk/python 0.42.6 2.680.0 1.2.23 unstructured-client" try: if __package__ is not None: diff --git a/src/unstructured_client/models/shared/__init__.py b/src/unstructured_client/models/shared/__init__.py index 6fad0b49..aac23db6 100644 --- a/src/unstructured_client/models/shared/__init__.py +++ b/src/unstructured_client/models/shared/__init__.py @@ -256,6 +256,14 @@ OneDriveSourceConnectorConfigInput, OneDriveSourceConnectorConfigInputTypedDict, ) + from .opensearchconnectorconfig import ( + OpenSearchConnectorConfig, + OpenSearchConnectorConfigTypedDict, + ) + from .opensearchconnectorconfiginput import ( + OpenSearchConnectorConfigInput, + OpenSearchConnectorConfigInputTypedDict, + ) from .outlooksourceconnectorconfig import ( OutlookSourceConnectorConfig, OutlookSourceConnectorConfigTypedDict, @@ -570,6 +578,10 @@ "OneDriveSourceConnectorConfigInput", "OneDriveSourceConnectorConfigInputTypedDict", "OneDriveSourceConnectorConfigTypedDict", + "OpenSearchConnectorConfig", + "OpenSearchConnectorConfigInput", + "OpenSearchConnectorConfigInputTypedDict", + "OpenSearchConnectorConfigTypedDict", "OutlookSourceConnectorConfig", "OutlookSourceConnectorConfigInput", "OutlookSourceConnectorConfigInputTypedDict", @@ -823,6 +835,10 @@ "OneDriveSourceConnectorConfigTypedDict": ".onedrivesourceconnectorconfig", "OneDriveSourceConnectorConfigInput": ".onedrivesourceconnectorconfiginput", "OneDriveSourceConnectorConfigInputTypedDict": ".onedrivesourceconnectorconfiginput", + "OpenSearchConnectorConfig": ".opensearchconnectorconfig", + "OpenSearchConnectorConfigTypedDict": ".opensearchconnectorconfig", + "OpenSearchConnectorConfigInput": ".opensearchconnectorconfiginput", + "OpenSearchConnectorConfigInputTypedDict": ".opensearchconnectorconfiginput", "OutlookSourceConnectorConfig": ".outlooksourceconnectorconfig", "OutlookSourceConnectorConfigTypedDict": ".outlooksourceconnectorconfig", "OutlookSourceConnectorConfigInput": ".outlooksourceconnectorconfiginput", diff --git a/src/unstructured_client/models/shared/createdestinationconnector.py b/src/unstructured_client/models/shared/createdestinationconnector.py index a59ab5df..1e5dcb6c 100644 --- a/src/unstructured_client/models/shared/createdestinationconnector.py +++ b/src/unstructured_client/models/shared/createdestinationconnector.py @@ -62,6 +62,10 @@ OneDriveDestinationConnectorConfigInput, OneDriveDestinationConnectorConfigInputTypedDict, ) +from .opensearchconnectorconfiginput import ( + OpenSearchConnectorConfigInput, + OpenSearchConnectorConfigInputTypedDict, +) from .pineconedestinationconnectorconfiginput import ( PineconeDestinationConnectorConfigInput, PineconeDestinationConnectorConfigInputTypedDict, @@ -101,23 +105,24 @@ "ConfigTypedDict", Union[ GCSDestinationConnectorConfigInputTypedDict, + ElasticsearchConnectorConfigInputTypedDict, WeaviateDestinationConnectorConfigInputTypedDict, AzureAISearchConnectorConfigInputTypedDict, - ElasticsearchConnectorConfigInputTypedDict, MongoDBConnectorConfigInputTypedDict, QdrantCloudDestinationConnectorConfigInputTypedDict, - DeltaTableConnectorConfigInputTypedDict, PineconeDestinationConnectorConfigInputTypedDict, + DeltaTableConnectorConfigInputTypedDict, Neo4jDestinationConnectorConfigInputTypedDict, AzureDestinationConnectorConfigInputTypedDict, S3DestinationConnectorConfigInputTypedDict, OneDriveDestinationConnectorConfigInputTypedDict, - PostgresDestinationConnectorConfigInputTypedDict, MilvusDestinationConnectorConfigInputTypedDict, + CouchbaseDestinationConnectorConfigInputTypedDict, KafkaCloudDestinationConnectorConfigInputTypedDict, + PostgresDestinationConnectorConfigInputTypedDict, DatabricksVolumesConnectorConfigInputTypedDict, - CouchbaseDestinationConnectorConfigInputTypedDict, AstraDBConnectorConfigInputTypedDict, + OpenSearchConnectorConfigInputTypedDict, RedisDestinationConnectorConfigInputTypedDict, DatabricksVDTDestinationConnectorConfigInputTypedDict, SnowflakeDestinationConnectorConfigInputTypedDict, @@ -131,23 +136,24 @@ "Config", Union[ GCSDestinationConnectorConfigInput, + ElasticsearchConnectorConfigInput, WeaviateDestinationConnectorConfigInput, AzureAISearchConnectorConfigInput, - ElasticsearchConnectorConfigInput, MongoDBConnectorConfigInput, QdrantCloudDestinationConnectorConfigInput, - DeltaTableConnectorConfigInput, PineconeDestinationConnectorConfigInput, + DeltaTableConnectorConfigInput, Neo4jDestinationConnectorConfigInput, AzureDestinationConnectorConfigInput, S3DestinationConnectorConfigInput, OneDriveDestinationConnectorConfigInput, - PostgresDestinationConnectorConfigInput, MilvusDestinationConnectorConfigInput, + CouchbaseDestinationConnectorConfigInput, KafkaCloudDestinationConnectorConfigInput, + PostgresDestinationConnectorConfigInput, DatabricksVolumesConnectorConfigInput, - CouchbaseDestinationConnectorConfigInput, AstraDBConnectorConfigInput, + OpenSearchConnectorConfigInput, RedisDestinationConnectorConfigInput, DatabricksVDTDestinationConnectorConfigInput, SnowflakeDestinationConnectorConfigInput, diff --git a/src/unstructured_client/models/shared/createsourceconnector.py b/src/unstructured_client/models/shared/createsourceconnector.py index ddfcdf3a..d781619a 100644 --- a/src/unstructured_client/models/shared/createsourceconnector.py +++ b/src/unstructured_client/models/shared/createsourceconnector.py @@ -53,6 +53,10 @@ OneDriveSourceConnectorConfigInput, OneDriveSourceConnectorConfigInputTypedDict, ) +from .opensearchconnectorconfiginput import ( + OpenSearchConnectorConfigInput, + OpenSearchConnectorConfigInputTypedDict, +) from .outlooksourceconnectorconfiginput import ( OutlookSourceConnectorConfigInput, OutlookSourceConnectorConfigInputTypedDict, @@ -93,21 +97,22 @@ "CreateSourceConnectorConfigTypedDict", Union[ MongoDBConnectorConfigInputTypedDict, - BoxSourceConnectorConfigInputTypedDict, DropboxSourceConnectorConfigInputTypedDict, - ElasticsearchConnectorConfigInputTypedDict, + BoxSourceConnectorConfigInputTypedDict, GCSSourceConnectorConfigInputTypedDict, + ElasticsearchConnectorConfigInputTypedDict, SalesforceSourceConnectorConfigInputTypedDict, GoogleDriveSourceConnectorConfigInputTypedDict, ZendeskSourceConnectorConfigInputTypedDict, AzureSourceConnectorConfigInputTypedDict, + S3SourceConnectorConfigInputTypedDict, + DatabricksVolumesConnectorConfigInputTypedDict, OneDriveSourceConnectorConfigInputTypedDict, KafkaCloudSourceConnectorConfigInputTypedDict, OutlookSourceConnectorConfigInputTypedDict, - DatabricksVolumesConnectorConfigInputTypedDict, - S3SourceConnectorConfigInputTypedDict, - CouchbaseSourceConnectorConfigInputTypedDict, + OpenSearchConnectorConfigInputTypedDict, SharePointSourceConnectorConfigInputTypedDict, + CouchbaseSourceConnectorConfigInputTypedDict, PostgresSourceConnectorConfigInputTypedDict, JiraSourceConnectorConfigInputTypedDict, ConfluenceSourceConnectorConfigInputTypedDict, @@ -121,21 +126,22 @@ "CreateSourceConnectorConfig", Union[ MongoDBConnectorConfigInput, - BoxSourceConnectorConfigInput, DropboxSourceConnectorConfigInput, - ElasticsearchConnectorConfigInput, + BoxSourceConnectorConfigInput, GCSSourceConnectorConfigInput, + ElasticsearchConnectorConfigInput, SalesforceSourceConnectorConfigInput, GoogleDriveSourceConnectorConfigInput, ZendeskSourceConnectorConfigInput, AzureSourceConnectorConfigInput, + S3SourceConnectorConfigInput, + DatabricksVolumesConnectorConfigInput, OneDriveSourceConnectorConfigInput, KafkaCloudSourceConnectorConfigInput, OutlookSourceConnectorConfigInput, - DatabricksVolumesConnectorConfigInput, - S3SourceConnectorConfigInput, - CouchbaseSourceConnectorConfigInput, + OpenSearchConnectorConfigInput, SharePointSourceConnectorConfigInput, + CouchbaseSourceConnectorConfigInput, PostgresSourceConnectorConfigInput, JiraSourceConnectorConfigInput, ConfluenceSourceConnectorConfigInput, diff --git a/src/unstructured_client/models/shared/destinationconnectorinformation.py b/src/unstructured_client/models/shared/destinationconnectorinformation.py index 11237f6e..bfd953f1 100644 --- a/src/unstructured_client/models/shared/destinationconnectorinformation.py +++ b/src/unstructured_client/models/shared/destinationconnectorinformation.py @@ -62,6 +62,10 @@ OneDriveDestinationConnectorConfig, OneDriveDestinationConnectorConfigTypedDict, ) +from .opensearchconnectorconfig import ( + OpenSearchConnectorConfig, + OpenSearchConnectorConfigTypedDict, +) from .pineconedestinationconnectorconfig import ( PineconeDestinationConnectorConfig, PineconeDestinationConnectorConfigTypedDict, @@ -110,25 +114,26 @@ Union[ GCSDestinationConnectorConfigTypedDict, ElasticsearchConnectorConfigTypedDict, - MongoDBConnectorConfigTypedDict, - AzureAISearchConnectorConfigTypedDict, WeaviateDestinationConnectorConfigTypedDict, - DeltaTableConnectorConfigTypedDict, + AzureAISearchConnectorConfigTypedDict, + MongoDBConnectorConfigTypedDict, QdrantCloudDestinationConnectorConfigTypedDict, + DeltaTableConnectorConfigTypedDict, PineconeDestinationConnectorConfigTypedDict, AzureDestinationConnectorConfigTypedDict, Neo4jDestinationConnectorConfigTypedDict, OneDriveDestinationConnectorConfigTypedDict, - S3DestinationConnectorConfigTypedDict, AstraDBConnectorConfigTypedDict, - PostgresDestinationConnectorConfigTypedDict, + S3DestinationConnectorConfigTypedDict, MilvusDestinationConnectorConfigTypedDict, + CouchbaseDestinationConnectorConfigTypedDict, + PostgresDestinationConnectorConfigTypedDict, KafkaCloudDestinationConnectorConfigTypedDict, DatabricksVolumesConnectorConfigTypedDict, - CouchbaseDestinationConnectorConfigTypedDict, + OpenSearchConnectorConfigTypedDict, RedisDestinationConnectorConfigTypedDict, - DatabricksVDTDestinationConnectorConfigTypedDict, SnowflakeDestinationConnectorConfigTypedDict, + DatabricksVDTDestinationConnectorConfigTypedDict, IBMWatsonxS3DestinationConnectorConfigTypedDict, Dict[str, Any], ], @@ -140,25 +145,26 @@ Union[ GCSDestinationConnectorConfig, ElasticsearchConnectorConfig, - MongoDBConnectorConfig, - AzureAISearchConnectorConfig, WeaviateDestinationConnectorConfig, - DeltaTableConnectorConfig, + AzureAISearchConnectorConfig, + MongoDBConnectorConfig, QdrantCloudDestinationConnectorConfig, + DeltaTableConnectorConfig, PineconeDestinationConnectorConfig, AzureDestinationConnectorConfig, Neo4jDestinationConnectorConfig, OneDriveDestinationConnectorConfig, - S3DestinationConnectorConfig, AstraDBConnectorConfig, - PostgresDestinationConnectorConfig, + S3DestinationConnectorConfig, MilvusDestinationConnectorConfig, + CouchbaseDestinationConnectorConfig, + PostgresDestinationConnectorConfig, KafkaCloudDestinationConnectorConfig, DatabricksVolumesConnectorConfig, - CouchbaseDestinationConnectorConfig, + OpenSearchConnectorConfig, RedisDestinationConnectorConfig, - DatabricksVDTDestinationConnectorConfig, SnowflakeDestinationConnectorConfig, + DatabricksVDTDestinationConnectorConfig, IBMWatsonxS3DestinationConnectorConfig, Dict[str, Any], ], diff --git a/src/unstructured_client/models/shared/destinationconnectortype.py b/src/unstructured_client/models/shared/destinationconnectortype.py index d463db75..b01ceb60 100644 --- a/src/unstructured_client/models/shared/destinationconnectortype.py +++ b/src/unstructured_client/models/shared/destinationconnectortype.py @@ -21,6 +21,7 @@ class DestinationConnectorType(str, Enum, metaclass=utils.OpenEnumMeta): MOTHERDUCK = "motherduck" NEO4J = "neo4j" ONEDRIVE = "onedrive" + OPENSEARCH = "opensearch" PINECONE = "pinecone" POSTGRES = "postgres" REDIS = "redis" diff --git a/src/unstructured_client/models/shared/opensearchconnectorconfig.py b/src/unstructured_client/models/shared/opensearchconnectorconfig.py new file mode 100644 index 00000000..7cc7a215 --- /dev/null +++ b/src/unstructured_client/models/shared/opensearchconnectorconfig.py @@ -0,0 +1,124 @@ +"""Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.""" + +from __future__ import annotations +from pydantic import model_serializer +from typing import List +from typing_extensions import NotRequired, TypedDict +from unstructured_client.types import ( + BaseModel, + Nullable, + OptionalNullable, + UNSET, + UNSET_SENTINEL, +) + + +class OpenSearchConnectorConfigTypedDict(TypedDict): + r"""OpenSearch connector configuration. + + OpenSearch is a fork of Elasticsearch with similar functionality. + Supports two authentication methods: + 1. Basic auth: username + password + 2. AWS IAM auth: aws_access_key_id + aws_secret_access_key (+ optional aws_session_token) + + For AWS OpenSearch Service or OpenSearch Serverless, region and service type + are auto-detected from the host URL. + """ + + hosts: List[str] + r"""List of OpenSearch hosts to connect to""" + index_name: str + r"""Name of the OpenSearch index to read from or write to""" + aws_access_key_id: NotRequired[Nullable[str]] + r"""AWS access key ID for IAM authentication. When provided with aws_secret_access_key, IAM authentication is used instead of basic auth. Region and service type are auto-detected from the host URL.""" + aws_secret_access_key: NotRequired[Nullable[str]] + r"""AWS secret access key for IAM authentication. Required when aws_access_key_id is provided.""" + aws_session_token: NotRequired[Nullable[str]] + r"""AWS session token for temporary credentials (optional). Only used when aws_access_key_id and aws_secret_access_key are provided.""" + password: NotRequired[Nullable[str]] + r"""Password for basic authentication""" + use_ssl: NotRequired[Nullable[bool]] + r"""Whether to use SSL for the connection""" + username: NotRequired[Nullable[str]] + r"""Username for basic authentication""" + + +class OpenSearchConnectorConfig(BaseModel): + r"""OpenSearch connector configuration. + + OpenSearch is a fork of Elasticsearch with similar functionality. + Supports two authentication methods: + 1. Basic auth: username + password + 2. AWS IAM auth: aws_access_key_id + aws_secret_access_key (+ optional aws_session_token) + + For AWS OpenSearch Service or OpenSearch Serverless, region and service type + are auto-detected from the host URL. + """ + + hosts: List[str] + r"""List of OpenSearch hosts to connect to""" + + index_name: str + r"""Name of the OpenSearch index to read from or write to""" + + aws_access_key_id: OptionalNullable[str] = UNSET + r"""AWS access key ID for IAM authentication. When provided with aws_secret_access_key, IAM authentication is used instead of basic auth. Region and service type are auto-detected from the host URL.""" + + aws_secret_access_key: OptionalNullable[str] = UNSET + r"""AWS secret access key for IAM authentication. Required when aws_access_key_id is provided.""" + + aws_session_token: OptionalNullable[str] = UNSET + r"""AWS session token for temporary credentials (optional). Only used when aws_access_key_id and aws_secret_access_key are provided.""" + + password: OptionalNullable[str] = UNSET + r"""Password for basic authentication""" + + use_ssl: OptionalNullable[bool] = UNSET + r"""Whether to use SSL for the connection""" + + username: OptionalNullable[str] = UNSET + r"""Username for basic authentication""" + + @model_serializer(mode="wrap") + def serialize_model(self, handler): + optional_fields = [ + "aws_access_key_id", + "aws_secret_access_key", + "aws_session_token", + "password", + "use_ssl", + "username", + ] + nullable_fields = [ + "aws_access_key_id", + "aws_secret_access_key", + "aws_session_token", + "password", + "use_ssl", + "username", + ] + null_default_fields = [] + + serialized = handler(self) + + m = {} + + for n, f in type(self).model_fields.items(): + k = f.alias or n + val = serialized.get(k) + serialized.pop(k, None) + + optional_nullable = k in optional_fields and k in nullable_fields + is_set = ( + self.__pydantic_fields_set__.intersection({n}) + or k in null_default_fields + ) # pylint: disable=no-member + + if val is not None and val != UNSET_SENTINEL: + m[k] = val + elif val != UNSET_SENTINEL and ( + not k in optional_fields or (optional_nullable and is_set) + ): + m[k] = val + + return m diff --git a/src/unstructured_client/models/shared/opensearchconnectorconfiginput.py b/src/unstructured_client/models/shared/opensearchconnectorconfiginput.py new file mode 100644 index 00000000..ca3975de --- /dev/null +++ b/src/unstructured_client/models/shared/opensearchconnectorconfiginput.py @@ -0,0 +1,106 @@ +"""Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.""" + +from __future__ import annotations +from pydantic import model_serializer +from typing import List +from typing_extensions import NotRequired, TypedDict +from unstructured_client.types import ( + BaseModel, + Nullable, + OptionalNullable, + UNSET, + UNSET_SENTINEL, +) + + +class OpenSearchConnectorConfigInputTypedDict(TypedDict): + r"""Input model for creating/updating OpenSearch connectors via API.""" + + hosts: List[str] + r"""List of OpenSearch hosts to connect to""" + index_name: str + r"""Name of the OpenSearch index to read from or write to""" + aws_access_key_id: NotRequired[Nullable[str]] + r"""AWS access key ID for IAM authentication. When provided with aws_secret_access_key, IAM authentication is used instead of basic auth. Region and service type are auto-detected from the host URL.""" + aws_secret_access_key: NotRequired[Nullable[str]] + r"""AWS secret access key for IAM authentication. Required when aws_access_key_id is provided.""" + aws_session_token: NotRequired[Nullable[str]] + r"""AWS session token for temporary credentials (optional). Only used when aws_access_key_id and aws_secret_access_key are provided.""" + password: NotRequired[Nullable[str]] + r"""Password for basic authentication""" + use_ssl: NotRequired[Nullable[bool]] + r"""Whether to use SSL for the connection""" + username: NotRequired[Nullable[str]] + r"""Username for basic authentication""" + + +class OpenSearchConnectorConfigInput(BaseModel): + r"""Input model for creating/updating OpenSearch connectors via API.""" + + hosts: List[str] + r"""List of OpenSearch hosts to connect to""" + + index_name: str + r"""Name of the OpenSearch index to read from or write to""" + + aws_access_key_id: OptionalNullable[str] = UNSET + r"""AWS access key ID for IAM authentication. When provided with aws_secret_access_key, IAM authentication is used instead of basic auth. Region and service type are auto-detected from the host URL.""" + + aws_secret_access_key: OptionalNullable[str] = UNSET + r"""AWS secret access key for IAM authentication. Required when aws_access_key_id is provided.""" + + aws_session_token: OptionalNullable[str] = UNSET + r"""AWS session token for temporary credentials (optional). Only used when aws_access_key_id and aws_secret_access_key are provided.""" + + password: OptionalNullable[str] = UNSET + r"""Password for basic authentication""" + + use_ssl: OptionalNullable[bool] = UNSET + r"""Whether to use SSL for the connection""" + + username: OptionalNullable[str] = UNSET + r"""Username for basic authentication""" + + @model_serializer(mode="wrap") + def serialize_model(self, handler): + optional_fields = [ + "aws_access_key_id", + "aws_secret_access_key", + "aws_session_token", + "password", + "use_ssl", + "username", + ] + nullable_fields = [ + "aws_access_key_id", + "aws_secret_access_key", + "aws_session_token", + "password", + "use_ssl", + "username", + ] + null_default_fields = [] + + serialized = handler(self) + + m = {} + + for n, f in type(self).model_fields.items(): + k = f.alias or n + val = serialized.get(k) + serialized.pop(k, None) + + optional_nullable = k in optional_fields and k in nullable_fields + is_set = ( + self.__pydantic_fields_set__.intersection({n}) + or k in null_default_fields + ) # pylint: disable=no-member + + if val is not None and val != UNSET_SENTINEL: + m[k] = val + elif val != UNSET_SENTINEL and ( + not k in optional_fields or (optional_nullable and is_set) + ): + m[k] = val + + return m diff --git a/src/unstructured_client/models/shared/sourceconnectorinformation.py b/src/unstructured_client/models/shared/sourceconnectorinformation.py index c2510fdc..a1298793 100644 --- a/src/unstructured_client/models/shared/sourceconnectorinformation.py +++ b/src/unstructured_client/models/shared/sourceconnectorinformation.py @@ -53,6 +53,10 @@ OneDriveSourceConnectorConfig, OneDriveSourceConnectorConfigTypedDict, ) +from .opensearchconnectorconfig import ( + OpenSearchConnectorConfig, + OpenSearchConnectorConfigTypedDict, +) from .outlooksourceconnectorconfig import ( OutlookSourceConnectorConfig, OutlookSourceConnectorConfigTypedDict, @@ -105,15 +109,16 @@ DropboxSourceConnectorConfigTypedDict, ElasticsearchConnectorConfigTypedDict, GCSSourceConnectorConfigTypedDict, - SalesforceSourceConnectorConfigTypedDict, GoogleDriveSourceConnectorConfigTypedDict, + SalesforceSourceConnectorConfigTypedDict, ZendeskSourceConnectorConfigTypedDict, AzureSourceConnectorConfigTypedDict, S3SourceConnectorConfigTypedDict, + DatabricksVolumesConnectorConfigTypedDict, + KafkaCloudSourceConnectorConfigTypedDict, OutlookSourceConnectorConfigTypedDict, OneDriveSourceConnectorConfigTypedDict, - KafkaCloudSourceConnectorConfigTypedDict, - DatabricksVolumesConnectorConfigTypedDict, + OpenSearchConnectorConfigTypedDict, SharePointSourceConnectorConfigTypedDict, CouchbaseSourceConnectorConfigTypedDict, PostgresSourceConnectorConfigTypedDict, @@ -133,15 +138,16 @@ DropboxSourceConnectorConfig, ElasticsearchConnectorConfig, GCSSourceConnectorConfig, - SalesforceSourceConnectorConfig, GoogleDriveSourceConnectorConfig, + SalesforceSourceConnectorConfig, ZendeskSourceConnectorConfig, AzureSourceConnectorConfig, S3SourceConnectorConfig, + DatabricksVolumesConnectorConfig, + KafkaCloudSourceConnectorConfig, OutlookSourceConnectorConfig, OneDriveSourceConnectorConfig, - KafkaCloudSourceConnectorConfig, - DatabricksVolumesConnectorConfig, + OpenSearchConnectorConfig, SharePointSourceConnectorConfig, CouchbaseSourceConnectorConfig, PostgresSourceConnectorConfig, diff --git a/src/unstructured_client/models/shared/sourceconnectortype.py b/src/unstructured_client/models/shared/sourceconnectortype.py index 3e0bd03e..dcd65a77 100644 --- a/src/unstructured_client/models/shared/sourceconnectortype.py +++ b/src/unstructured_client/models/shared/sourceconnectortype.py @@ -18,6 +18,7 @@ class SourceConnectorType(str, Enum, metaclass=utils.OpenEnumMeta): KAFKA_CLOUD = "kafka-cloud" MONGODB = "mongodb" ONEDRIVE = "onedrive" + OPENSEARCH = "opensearch" OUTLOOK = "outlook" POSTGRES = "postgres" S3 = "s3" diff --git a/src/unstructured_client/models/shared/updatedestinationconnector.py b/src/unstructured_client/models/shared/updatedestinationconnector.py index 71b95975..b622261b 100644 --- a/src/unstructured_client/models/shared/updatedestinationconnector.py +++ b/src/unstructured_client/models/shared/updatedestinationconnector.py @@ -61,6 +61,10 @@ OneDriveDestinationConnectorConfigInput, OneDriveDestinationConnectorConfigInputTypedDict, ) +from .opensearchconnectorconfiginput import ( + OpenSearchConnectorConfigInput, + OpenSearchConnectorConfigInputTypedDict, +) from .pineconedestinationconnectorconfiginput import ( PineconeDestinationConnectorConfigInput, PineconeDestinationConnectorConfigInputTypedDict, @@ -98,23 +102,24 @@ "UpdateDestinationConnectorConfigTypedDict", Union[ GCSDestinationConnectorConfigInputTypedDict, + ElasticsearchConnectorConfigInputTypedDict, WeaviateDestinationConnectorConfigInputTypedDict, AzureAISearchConnectorConfigInputTypedDict, - ElasticsearchConnectorConfigInputTypedDict, MongoDBConnectorConfigInputTypedDict, QdrantCloudDestinationConnectorConfigInputTypedDict, - DeltaTableConnectorConfigInputTypedDict, PineconeDestinationConnectorConfigInputTypedDict, + DeltaTableConnectorConfigInputTypedDict, Neo4jDestinationConnectorConfigInputTypedDict, AzureDestinationConnectorConfigInputTypedDict, S3DestinationConnectorConfigInputTypedDict, OneDriveDestinationConnectorConfigInputTypedDict, - PostgresDestinationConnectorConfigInputTypedDict, MilvusDestinationConnectorConfigInputTypedDict, + CouchbaseDestinationConnectorConfigInputTypedDict, KafkaCloudDestinationConnectorConfigInputTypedDict, + PostgresDestinationConnectorConfigInputTypedDict, DatabricksVolumesConnectorConfigInputTypedDict, - CouchbaseDestinationConnectorConfigInputTypedDict, AstraDBConnectorConfigInputTypedDict, + OpenSearchConnectorConfigInputTypedDict, RedisDestinationConnectorConfigInputTypedDict, DatabricksVDTDestinationConnectorConfigInputTypedDict, SnowflakeDestinationConnectorConfigInputTypedDict, @@ -128,23 +133,24 @@ "UpdateDestinationConnectorConfig", Union[ GCSDestinationConnectorConfigInput, + ElasticsearchConnectorConfigInput, WeaviateDestinationConnectorConfigInput, AzureAISearchConnectorConfigInput, - ElasticsearchConnectorConfigInput, MongoDBConnectorConfigInput, QdrantCloudDestinationConnectorConfigInput, - DeltaTableConnectorConfigInput, PineconeDestinationConnectorConfigInput, + DeltaTableConnectorConfigInput, Neo4jDestinationConnectorConfigInput, AzureDestinationConnectorConfigInput, S3DestinationConnectorConfigInput, OneDriveDestinationConnectorConfigInput, - PostgresDestinationConnectorConfigInput, MilvusDestinationConnectorConfigInput, + CouchbaseDestinationConnectorConfigInput, KafkaCloudDestinationConnectorConfigInput, + PostgresDestinationConnectorConfigInput, DatabricksVolumesConnectorConfigInput, - CouchbaseDestinationConnectorConfigInput, AstraDBConnectorConfigInput, + OpenSearchConnectorConfigInput, RedisDestinationConnectorConfigInput, DatabricksVDTDestinationConnectorConfigInput, SnowflakeDestinationConnectorConfigInput, diff --git a/src/unstructured_client/models/shared/updatesourceconnector.py b/src/unstructured_client/models/shared/updatesourceconnector.py index d7d35077..d975e671 100644 --- a/src/unstructured_client/models/shared/updatesourceconnector.py +++ b/src/unstructured_client/models/shared/updatesourceconnector.py @@ -53,6 +53,10 @@ OneDriveSourceConnectorConfigInput, OneDriveSourceConnectorConfigInputTypedDict, ) +from .opensearchconnectorconfiginput import ( + OpenSearchConnectorConfigInput, + OpenSearchConnectorConfigInputTypedDict, +) from .outlooksourceconnectorconfiginput import ( OutlookSourceConnectorConfigInput, OutlookSourceConnectorConfigInputTypedDict, @@ -90,21 +94,22 @@ "UpdateSourceConnectorConfigTypedDict", Union[ MongoDBConnectorConfigInputTypedDict, - BoxSourceConnectorConfigInputTypedDict, DropboxSourceConnectorConfigInputTypedDict, - ElasticsearchConnectorConfigInputTypedDict, + BoxSourceConnectorConfigInputTypedDict, GCSSourceConnectorConfigInputTypedDict, + ElasticsearchConnectorConfigInputTypedDict, SalesforceSourceConnectorConfigInputTypedDict, GoogleDriveSourceConnectorConfigInputTypedDict, ZendeskSourceConnectorConfigInputTypedDict, AzureSourceConnectorConfigInputTypedDict, + S3SourceConnectorConfigInputTypedDict, + DatabricksVolumesConnectorConfigInputTypedDict, OneDriveSourceConnectorConfigInputTypedDict, KafkaCloudSourceConnectorConfigInputTypedDict, OutlookSourceConnectorConfigInputTypedDict, - DatabricksVolumesConnectorConfigInputTypedDict, - S3SourceConnectorConfigInputTypedDict, - CouchbaseSourceConnectorConfigInputTypedDict, + OpenSearchConnectorConfigInputTypedDict, SharePointSourceConnectorConfigInputTypedDict, + CouchbaseSourceConnectorConfigInputTypedDict, PostgresSourceConnectorConfigInputTypedDict, JiraSourceConnectorConfigInputTypedDict, ConfluenceSourceConnectorConfigInputTypedDict, @@ -118,21 +123,22 @@ "UpdateSourceConnectorConfig", Union[ MongoDBConnectorConfigInput, - BoxSourceConnectorConfigInput, DropboxSourceConnectorConfigInput, - ElasticsearchConnectorConfigInput, + BoxSourceConnectorConfigInput, GCSSourceConnectorConfigInput, + ElasticsearchConnectorConfigInput, SalesforceSourceConnectorConfigInput, GoogleDriveSourceConnectorConfigInput, ZendeskSourceConnectorConfigInput, AzureSourceConnectorConfigInput, + S3SourceConnectorConfigInput, + DatabricksVolumesConnectorConfigInput, OneDriveSourceConnectorConfigInput, KafkaCloudSourceConnectorConfigInput, OutlookSourceConnectorConfigInput, - DatabricksVolumesConnectorConfigInput, - S3SourceConnectorConfigInput, - CouchbaseSourceConnectorConfigInput, + OpenSearchConnectorConfigInput, SharePointSourceConnectorConfigInput, + CouchbaseSourceConnectorConfigInput, PostgresSourceConnectorConfigInput, JiraSourceConnectorConfigInput, ConfluenceSourceConnectorConfigInput,