docs(samples): Add Create Corpus with Feature Store

Author: holtskinner

generative_ai/rag/create_corpus_example.py

@@ -15,7 +15,7 @@
 
 from typing import Optional
 
-from google.cloud.aiplatform_v1beta1 import RagCorpus
+from vertexai.preview.rag import RagCorpus
 
 PROJECT_ID = os.getenv("GOOGLE_CLOUD_PROJECT")
 
@@ -37,7 +37,7 @@ def create_corpus(
     # Initialize Vertex AI API once per session
     vertexai.init(project=PROJECT_ID, location="us-central1")
 
-    # Configure embedding model
+    # Configure embedding model (Optional)
     embedding_model_config = rag.EmbeddingModelConfig(
         publisher_model="publishers/google/models/text-embedding-004"
     )

generative_ai/rag/create_corpus_feature_store_example.py

@@ -0,0 +1,71 @@
+# Copyright 2024 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#    https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+import os
+
+from typing import Optional
+
+from vertexai.preview.rag import RagCorpus
+
+PROJECT_ID = os.getenv("GOOGLE_CLOUD_PROJECT")
+
+
+def create_corpus_feature_store(
+    feature_view_name: str,
+    display_name: Optional[str] = None,
+    description: Optional[str] = None,
+) -> RagCorpus:
+    # [START generativeaionvertexai_rag_create_corpus_feature_store]
+
+    from vertexai.preview import rag
+    import vertexai
+
+    # TODO(developer): Update and un-comment below lines
+    # PROJECT_ID = "your-project-id"
+    # feature_view_name = "projects/{PROJECT_ID}/locations/{LOCATION}/featureOnlineStores/{FEATURE_ONLINE_STORE_ID}/featureViews/{FEATURE_VIEW_ID}"
+    # display_name = "test_corpus"
+    # description = "Corpus Description"
+
+    # Initialize Vertex AI API once per session
+    vertexai.init(project=PROJECT_ID, location="us-central1")
+
+    # Configure embedding model (Optional)
+    embedding_model_config = rag.EmbeddingModelConfig(
+        publisher_model="publishers/google/models/text-embedding-004"
+    )
+
+    # Configure Vector DB
+    vector_db = rag.VertexFeatureStore(resource_name=feature_view_name)
+
+    corpus = rag.create_corpus(
+        display_name=display_name,
+        description=description,
+        embedding_model_config=embedding_model_config,
+        vector_db=vector_db,
+    )
+    print(corpus)
+    # Example response:
+    # RagCorpus(name='projects/1234567890/locations/us-central1/ragCorpora/1234567890',
+    # display_name='test_corpus', description='Corpus Description', embedding_model_config=...
+    # ...
+
+    # [END generativeaionvertexai_rag_create_corpus_feature_store]
+    return corpus
+
+
+if __name__ == "__main__":
+    create_corpus_feature_store(
+        feature_view_name="projects/{PROJECT_ID}/locations/{LOCATION}/featureOnlineStores/{FEATURE_ONLINE_STORE_ID}/featureViews/{FEATURE_VIEW_ID}",
+        display_name="test_corpus",
+        description="Corpus Description",
+    )