Python: Added FT.CREATE command

CHANGELOG.md

@@ -1,4 +1,5 @@
 #### Changes
+* Python: [Python]Added [FT.CREATE] command ([#2413](https://github.com/valkey-io/valkey-glide/pull/2413))
 * Node: Fix binary variant for xinfogroups and lrem ([#2324](https://github.com/valkey-io/valkey-glide/pull/2324))
 * Node: Fixed missing exports ([#2301](https://github.com/valkey-io/valkey-glide/pull/2301))
 * Node: Use `options` struct for all optional arguments ([#2287](https://github.com/valkey-io/valkey-glide/pull/2287))

python/python/glide/async_commands/server_modules/ft.py

@@ -0,0 +1,58 @@
+# Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
+"""
+module for `vector search` commands.
+"""
+
+from typing import List, Optional, cast
+
+from glide.async_commands.server_modules.ft_constants import (
+    CommandNames,
+    FtCreateKeywords,
+)
+from glide.async_commands.server_modules.ft_options.ft_create_options import (
+    Field,
+    FtCreateOptions,
+)
+from glide.constants import TOK, TEncodable
+from glide.glide_client import TGlideClient
+
+
+async def create(
+    client: TGlideClient,
+    indexName: TEncodable,
+    schema: List[Field] = [],
+    options: Optional[FtCreateOptions] = None,
+) -> TOK:
+    """
+    Creates an index and initiates a backfill of that index.
+
+    See https://valkey.io/commands/ft.create/ for more details.
+
+        Args:
+        client (TGlideClient): The client to execute the command.
+        indexName (TEncodable): The index name for the index to be created
+        schema (List[Field]): The fields of the index schema, specifying the fields and their types.
+        options (Optional[FtCreateOptions]): Optional arguments for the [FT.CREATE] command.
+
+    Returns:
+        If the index is successfully created, returns OK.
+
+    Examples:
+        >>> from glide.async_commands.server_modules import ft
+        >>> schema: List[Field] = []
+        >>> field: TextField = TextField("title")
+        >>> schema.append(field)
+        >>> prefixes: List[str] = []
+        >>> prefixes.append("blog:post:")
+        >>> index = "idx"
+        >>> result = await ft.create(glide_client, index, schema, FtCreateOptions(DataType.HASH, prefixes))
+            'OK'  # Indicates successful creation of index named 'idx'
+    """
+    args: List[TEncodable] = [CommandNames.FT_CREATE, indexName]
+    if options:
+        args.extend(options.getCreateOptions())
+    if schema and len(schema) > 0:
+        args.append(FtCreateKeywords.SCHEMA)
+        for field in schema:
+            args.extend(field.getFieldArgs())
+    return cast(TOK, await client.custom_command(args))

python/python/glide/async_commands/server_modules/ft_constants.py

@@ -0,0 +1,29 @@
+class CommandNames:
+    """
+    Command name constants for vector search.
+    """
+
+    FT_CREATE = "FT.CREATE"
+
+
+class FtCreateKeywords:
+    """
+    Keywords used in the [FT.CREATE] command statment.
+    """
+
+    SCHEMA = "SCHEMA"
+    AS = "AS"
+    SORTABLE = "SORTABLE"
+    UNF = "UNF"
+    NO_INDEX = "NOINDEX"
+    ON = "ON"
+    PREFIX = "PREFIX"
+    SEPARATOR = "SEPARATOR"
+    CASESENSITIVE = "CASESENSITIVE"
+    DIM = "DIM"
+    DISTANCE_METRIC = "DISTANCE_METRIC"
+    TYPE = "TYPE"
+    INITIAL_CAP = "INITIAL_CAP"
+    M = "M"
+    EF_CONSTRUCTION = "EF_CONSTRUCTION"
+    EF_RUNTIME = "EF_RUNTIME"