?hdZddlZddlmZmZddlmZddlmZm Z ddl m Z m Z m Z mZmZmZmZmZmZmZmZmZmZGdd e Zy) z GraphQL `Aggregate` command. N)ListOptional) Connection)_capitalize_first_letterfile_encoder_b64) WhereGraphQLFilter NearAudio NearDepth NearImageNearIMU NearObjectNearText NearThermal NearVector NearVideo MediaTypecZeZdZdZdedeffd ZdeddfdZddZd e ddfd Z d e ddfd Z d eddfd Z de ddfdZdeeddfdZde ddfdZde ddfdZde ddfdZdde deddfdZdde deddfdZdde deddfdZdde deddfdZdde deddfdZdde deddfdZdefdZxZS)AggregateBuilderzD AggregateBuilder class used to aggregate Weaviate objects. class_name connectionct||t||_d|_d|_g|_d|_d|_d|_ d|_ d|_ d|_ y)a2 Initialize a AggregateBuilder class instance. Parameters ---------- class_name : str Class name of the objects to be aggregated. connection : weaviate.connect.Connection Connection object to an active and running Weaviate instance. NF) super__init__r _class_name _object_limit_with_meta_count_fields_where_group_by_properties _uses_filter_near_tenant_limit)selfrr __class__s T/home/chris/cleankitchens-env/lib/python3.12/site-packages/weaviate/gql/aggregate.pyrzAggregateBuilder.__init__"sb $ 8 D,0&+"$ '+ 9=!"''+ &* %) tenantreturncXt|ts td||_d|_|S)zSets a tenant for the query.ztenant must be of type strT) isinstancestr TypeErrorr%r#)r'r+s r) with_tenantzAggregateBuilder.with_tenant:s,&#&89 9   r*cd|_|S)z Set Meta Count to True. Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. T)r)r's r)with_meta_countz AggregateBuilder.with_meta_countCs!% r*limitc||_|S)a] Set objectLimit to limit vector search results used within the aggregation query only when with near filter. Parameters ---------- limit : int The object limit. Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. )rr'r4s r)with_object_limitz"AggregateBuilder.with_object_limitPs # r*c||_|S)a( Set limit to limit the number of returned results from the aggregation query. Parameters ---------- limit : int The limit. Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. )r&r6s r) with_limitzAggregateBuilder.with_limitcs  r*fieldc<|jj||S)aM Include a field in the aggregate query. Parameters ---------- field : str Field to include in the aggregate query. e.g. ' { count }' Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. )r append)r'r:s r) with_fieldszAggregateBuilder.with_fieldsus E" r*contentc4t||_d|_|S)a Set 'where' filter. Parameters ---------- content : dict The where filter to include in the aggregate query. See examples below. Examples -------- The `content` prototype is like this: >>> content = { ... 'operator': '', ... 'operands': [ ... { ... 'path': [path], ... 'operator': '' ... '': ... }, ... { ... 'path': [], ... 'operator': '', ... '': ... } ... ] ... } This is a complete `where` filter but it does not have to be like this all the time. Single operand: >>> content = { ... 'path': ["wordCount"], # Path to the property that should be used ... 'operator': 'GreaterThan', # operator ... 'valueInt': 1000 # value (which is always = to the type of the path property) ... } Or >>> content = { ... 'path': ["id"], ... 'operator': 'Equal', ... 'valueString': "e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf" ... } Multiple operands: >>> content = { ... 'operator': 'And', ... 'operands': [ ... { ... 'path': ["wordCount"], ... 'operator': 'GreaterThan', ... 'valueInt': 1000 ... }, ... { ... 'path': ["wordCount"], ... 'operator': 'LessThan', ... 'valueInt': 1500 ... } ... ] ... } Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. T)r r!r#r'r>s r) with_wherezAggregateBuilder.with_wheresNGn   r* propertiesc"||_d|_|S)a Add a group by filter to the query. Might requires the user to set an additional group by clause using `with_fields(..)`. Parameters ---------- properties : list of str list of properties that are included in the group by filter. Generates a filter like: 'groupBy: ["property1", "property2"]' from a list ["property1", "property2"] Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. T)r"r#)r'rBs r)with_group_by_filterz%AggregateBuilder.with_group_by_filters$%/!  r*cb|j tdt||_d|_|S)a Set `nearText` filter. This filter can be used with text modules (text2vec). E.g.: text2vec-contextionary, text2vec-transformers. NOTE: The 'autocorrect' field is enabled only with the `text-spellcheck` Weaviate module. Parameters ---------- content : dict The content of the `nearText` filter to set. See examples below. Examples -------- Content full prototype: >>> content = { ... 'concepts': , ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... 'moveAwayFrom': { # Optional ... 'concepts': , ... 'force': ... }, ... 'moveTo': { # Optional ... 'concepts': , ... 'force': ... }, ... 'autocorrect': , # Optional ... } Full content: >>> content = { ... 'concepts': ["fashion"], ... 'certainty': 0.7, # or 'distance' instead ... 'moveAwayFrom': { ... 'concepts': ["finance"], ... 'force': 0.45 ... }, ... 'moveTo': { ... 'concepts': ["haute couture"], ... 'force': 0.85 ... }, ... 'autocorrect': True ... } Partial content: >>> content = { ... 'concepts': ["fashion"], ... 'certainty': 0.7, # or 'distance' instead ... 'moveTo': { ... 'concepts': ["haute couture"], ... 'force': 0.85 ... } ... } Minimal content: >>> content = { ... 'concepts': "fashion" ... } Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. #Cannot use multiple 'near' filters.T)r$AttributeErrorrr#r@s r)with_near_textzAggregateBuilder.with_near_texts4V :: ! !FG Gg&   r*cb|j tdt||_d|_|S)a Set `nearVector` filter. Parameters ---------- content : dict The content of the `nearVector` filter to set. See examples below. Examples -------- Content full prototype: >>> content = { ... 'vector' : , ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... } NOTE: Supported types for 'vector' are `list`, 'numpy.ndarray`, `torch.Tensor` and `tf.Tensor`. Full content: >>> content = { ... 'vector' : [.1, .2, .3, .5], ... 'certainty': 0.75, # or 'distance' instead ... } Minimal content: >>> content = { ... 'vector' : [.1, .2, .3, .5] ... } Or >>> content = { ... 'vector' : torch.tensor([.1, .2, .3, .5]) ... } Or >>> content = { ... 'vector' : torch.tensor([[.1, .2, .3, .5]]) # it is going to be squeezed. ... } Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. rFT)r$rGrr#r@s r)with_near_vectorz!AggregateBuilder.with_near_vector:s4v :: ! !FG G(   r*c|jjdk\}|j tdt |||_d|_|S)a Set `nearObject` filter. Parameters ---------- content : dict The content of the `nearObject` filter to set. See examples below. Examples -------- Content prototype: >>> content = { ... 'id': , # OR 'beacon' ... 'beacon': , # OR 'id' ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... } >>> { ... 'id': "e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf", ... 'certainty': 0.7 # or 'distance' instead ... } >>> # alternatively >>> { ... 'beacon': "weaviate://localhost/Book/e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf" ... 'certainty': 0.7 # or 'distance' instead ... } Returns ------- weaviate.gql.aggregate.AggregateBuilder Updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. z1.14rFT) _connectionserver_versionr$rGrr#)r'r>is_server_version_14s r)with_near_objectz!AggregateBuilder.with_near_object{sNT $//>>&H :: ! !FG G)=>   r*encodectj|_|j t d|rt |d|d<t ||_d|_|S)a Set `nearImage` filter. Parameters ---------- content : dict The content of the `nearImage` filter to set. See examples below. encode : bool, optional Whether to encode the `content["image"]` to base64 and convert to string. If True, the `content["image"]` can be an image path or a file opened in binary read mode. If False, the `content["image"]` MUST be a base64 encoded string (NOT bytes, i.e. NOT binary string that looks like this: b'BASE64ENCODED' but simple 'BASE64ENCODED'). By default True. Examples -------- Content prototype: >>> content = { ... 'image': , ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... } >>> { ... 'image': "e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf", ... 'certainty': 0.7 # or 'distance' ... } With `encoded` True: >>> content = { ... 'image': "my_image_path.png", ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Image')\ .with_fields('description')\ ... .with_near_image(content, encode=True) # <- encode MUST be set to True OR >>> my_image_file = open("my_image_path.png", "br") >>> content = { ... 'image': my_image_file, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Image')\ .with_fields('description')\ ... .with_near_image(content, encode=True) # <- encode MUST be set to True >>> my_image_file.close() With `encoded` False: >>> from weaviate.util import image_encoder_b64, image_decoder_b64 >>> encoded_image = image_encoder_b64("my_image_path.png") >>> content = { ... 'image': encoded_image, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Image')\ .with_fields('description')\ ... .with_near_image(content, encode=False) # <- encode MUST be set to False OR >>> from weaviate.util import image_encoder_b64, image_decoder_b64 >>> with open("my_image_path.png", "br") as my_image_file: ... encoded_image = image_encoder_b64(my_image_file) >>> content = { ... 'image': encoded_image, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Image')\ .with_fields('description')\ ... .with_near_image(content, encode=False) # <- encode MUST be set to False Encode Image yourself: >>> import base64 >>> with open("my_image_path.png", "br") as my_image_file: ... encoded_image = base64.b64encode(my_image_file.read()).decode("utf-8") >>> content = { ... 'image': encoded_image, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Image')\ .with_fields('description')\ ... .with_near_image(content, encode=False) # <- encode MUST be set to False Returns ------- weaviate.gql.aggregate.AggregateBuilder The updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. QCannot use multiple 'near' filters, or a 'near' filter along with a 'ask' filter!imageT)rIMAGE _media_typer$rGrrr#r'r>rPs r)with_near_imagez AggregateBuilder.with_near_images_J%?? :: ! (  /0@AGG w'   r*ctj|_|j t d|r9t ||jj ||jj <t||_d|_|S)a~ Set `nearAudio` filter. Parameters ---------- content : dict The content of the `nearAudio` filter to set. See examples below. encode : bool, optional Whether to encode the `content["audio"]` to base64 and convert to string. If True, the `content["audio"]` can be an audio path or a file opened in binary read mode. If False, the `content["audio"]` MUST be a base64 encoded string (NOT bytes, i.e. NOT binary string that looks like this: b'BASE64ENCODED' but simple 'BASE64ENCODED'). By default True. Examples -------- Content prototype: >>> content = { ... 'audio': , ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... } >>> { ... 'audio': "e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf", ... 'certainty': 0.7 # or 'distance' ... } With `encoded` True: >>> content = { ... 'audio': "my_audio_path.wav", ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Audio')\ .with_fields('description')\ ... .with_near_audio(content, encode=True) # <- encode MUST be set to True OR >>> my_audio_file = open("my_audio_path.wav", "br") >>> content = { ... 'audio': my_audio_file, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Audio')\ .with_fields('description')\ ... .with_near_audio(content, encode=True) # <- encode MUST be set to True >>> my_audio_file.close() With `encoded` False: >>> from weaviate.util import file_encoder_b64 >>> encoded_audio = file_encoder_b64("my_audio_path.wav") >>> content = { ... 'audio': encoded_audio, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Audio')\ .with_fields('description')\ ... .with_near_audio(content, encode=False) # <- encode MUST be set to False OR >>> from weaviate.util import file_encoder_b64 >>> with open("my_audio_path.wav", "br") as my_audio_file: ... encoded_audio = file_encoder_b64(my_audio_file) >>> content = { ... 'audio': encoded_audio, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Audio')\ .with_fields('description')\ ... .with_near_audio(content, encode=False) # <- encode MUST be set to False Encode Audio yourself: >>> import base64 >>> with open("my_audio_path.wav", "br") as my_audio_file: ... encoded_audio = base64.b64encode(my_audio_file.read()).decode("utf-8") >>> content = { ... 'audio': encoded_audio, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Audio')\ .with_fields('description')\ ... .with_near_audio(content, encode=False) # <- encode MUST be set to False Returns ------- weaviate.gql.aggregate.AggregateBuilder The updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. rRT) rAUDIOrUr$rGrvaluer r#rVs r)with_near_audioz AggregateBuilder.with_near_audiowL%?? :: ! (  .>wtGWGWG]G]?^._GD$$** +w'   r*ctj|_|j t d|r9t ||jj ||jj <t||_d|_|S)a Set `nearVideo` filter. Parameters ---------- content : dict The content of the `nearVideo` filter to set. See examples below. encode : bool, optional Whether to encode the `content["video"]` to base64 and convert to string. If True, the `content["video"]` can be an video path or a file opened in binary read mode. If False, the `content["video"]` MUST be a base64 encoded string (NOT bytes, i.e. NOT binary string that looks like this: b'BASE64ENCODED' but simple 'BASE64ENCODED'). By default True. Examples -------- Content prototype: >>> content = { ... 'video': , ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... } >>> { ... 'video': "e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf", ... 'certainty': 0.7 # or 'distance' ... } With `encoded` True: >>> content = { ... 'video': "my_video_path.avi", ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Video')\ .with_fields('description')\ ... .with_near_video(content, encode=True) # <- encode MUST be set to True OR >>> my_video_file = open("my_video_path.avi", "br") >>> content = { ... 'video': my_video_file, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Video')\ .with_fields('description')\ ... .with_near_video(content, encode=True) # <- encode MUST be set to True >>> my_video_file.close() With `encoded` False: >>> from weaviate.util import file_encoder_b64 >>> encoded_video = file_encoder_b64("my_video_path.avi") >>> content = { ... 'video': encoded_video, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Video')\ .with_fields('description')\ ... .with_near_video(content, encode=False) # <- encode MUST be set to False OR >>> from weaviate.util import file_encoder_b64, video_decoder_b64 >>> with open("my_video_path.avi", "br") as my_video_file: ... encoded_video = file_encoder_b64(my_video_file) >>> content = { ... 'video': encoded_video, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Video')\ .with_fields('description')\ ... .with_near_video(content, encode=False) # <- encode MUST be set to False Encode Video yourself: >>> import base64 >>> with open("my_video_path.avi", "br") as my_video_file: ... encoded_video = base64.b64encode(my_video_file.read()).decode("utf-8") >>> content = { ... 'video': encoded_video, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Video')\ .with_fields('description')\ ... .with_near_video(content, encode=False) # <- encode MUST be set to False Returns ------- weaviate.gql.aggregate.AggregateBuilder The updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. rRT) rVIDEOrUr$rGrrZrr#rVs r)with_near_videoz AggregateBuilder.with_near_videor\r*ctj|_|j t d|r9t ||jj ||jj <t||_d|_|S)a~ Set `nearDepth` filter. Parameters ---------- content : dict The content of the `nearDepth` filter to set. See examples below. encode : bool, optional Whether to encode the `content["depth"]` to base64 and convert to string. If True, the `content["depth"]` can be an depth path or a file opened in binary read mode. If False, the `content["depth"]` MUST be a base64 encoded string (NOT bytes, i.e. NOT binary string that looks like this: b'BASE64ENCODED' but simple 'BASE64ENCODED'). By default True. Examples -------- Content prototype: >>> content = { ... 'depth': , ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... } >>> { ... 'depth': "e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf", ... 'certainty': 0.7 # or 'distance' ... } With `encoded` True: >>> content = { ... 'depth': "my_depth_path.png", ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Depth')\ .with_fields('description')\ ... .with_near_depth(content, encode=True) # <- encode MUST be set to True OR >>> my_depth_file = open("my_depth_path.png", "br") >>> content = { ... 'depth': my_depth_file, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Depth')\ .with_fields('description')\ ... .with_near_depth(content, encode=True) # <- encode MUST be set to True >>> my_depth_file.close() With `encoded` False: >>> from weaviate.util import file_encoder_b64 >>> encoded_depth = file_encoder_b64("my_depth_path.png") >>> content = { ... 'depth': encoded_depth, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Depth')\ .with_fields('description')\ ... .with_near_depth(content, encode=False) # <- encode MUST be set to False OR >>> from weaviate.util import file_encoder_b64 >>> with open("my_depth_path.png", "br") as my_depth_file: ... encoded_depth = file_encoder_b64(my_depth_file) >>> content = { ... 'depth': encoded_depth, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Depth')\ .with_fields('description')\ ... .with_near_depth(content, encode=False) # <- encode MUST be set to False Encode Depth yourself: >>> import base64 >>> with open("my_depth_path.png", "br") as my_depth_file: ... encoded_depth = base64.b64encode(my_depth_file.read()).decode("utf-8") >>> content = { ... 'depth': encoded_depth, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Depth')\ .with_fields('description')\ ... .with_near_depth(content, encode=False) # <- encode MUST be set to False Returns ------- weaviate.gql.aggregate.AggregateBuilder The updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. rRT) rDEPTHrUr$rGrrZr r#rVs r)with_near_depthz AggregateBuilder.with_near_depthr\r*ctj|_|j t d|r9t ||jj ||jj <t||_d|_|S)a Set `nearThermal` filter. Parameters ---------- content : dict The content of the `nearThermal` filter to set. See examples below. encode : bool, optional Whether to encode the `content["thermal"]` to base64 and convert to string. If True, the `content["thermal"]` can be an thermal path or a file opened in binary read mode. If False, the `content["thermal"]` MUST be a base64 encoded string (NOT bytes, i.e. NOT binary string that looks like this: b'BASE64ENCODED' but simple 'BASE64ENCODED'). By default True. Examples -------- Content prototype: >>> content = { ... 'thermal': , ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... } >>> { ... 'thermal': "e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf", ... 'certainty': 0.7 # or 'distance' ... } With `encoded` True: >>> content = { ... 'thermal': "my_thermal_path.png", ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.get('Thermal', 'description')\ ... .with_near_thermal(content, encode=True) # <- encode MUST be set to True OR >>> my_thermal_file = open("my_thermal_path.png", "br") >>> content = { ... 'thermal': my_thermal_file, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Thermal')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=True) # <- encode MUST be set to True >>> my_thermal_file.close() With `encoded` False: >>> from weaviate.util import file_encoder_b64 >>> encoded_thermal = file_encoder_b64("my_thermal_path.png") >>> content = { ... 'thermal': encoded_thermal, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Thermal')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=False) # <- encode MUST be set to False OR >>> from weaviate.util import file_encoder_b64 >>> with open("my_thermal_path.png", "br") as my_thermal_file: ... encoded_thermal = file_encoder_b64(my_thermal_file) >>> content = { ... 'thermal': encoded_thermal, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Thermal')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=False) # <- encode MUST be set to False Encode Thermal yourself: >>> import base64 >>> with open("my_thermal_path.png", "br") as my_thermal_file: ... encoded_thermal = base64.b64encode(my_thermal_file.read()).decode("utf-8") >>> content = { ... 'thermal': encoded_thermal, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('Thermal')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=False) # <- encode MUST be set to False Returns ------- weaviate.gql.aggregate.AggregateBuilder The updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. rRT) rTHERMALrUr$rGrrZrr#rVs r)with_near_thermalz"AggregateBuilder.with_near_thermaltsyJ%,, :: ! (  .>wtGWGWG]G]?^._GD$$** + )   r*ctj|_|j t d|r9t ||jj ||jj <t||_d|_|S)a Set `nearIMU` filter. Parameters ---------- content : dict The content of the `nearIMU` filter to set. See examples below. encode : bool, optional Whether to encode the `content["thermal"]` to base64 and convert to string. If True, the `content["thermal"]` can be an thermal path or a file opened in binary read mode. If False, the `content["thermal"]` MUST be a base64 encoded string (NOT bytes, i.e. NOT binary string that looks like this: b'BASE64ENCODED' but simple 'BASE64ENCODED'). By default True. Examples -------- Content prototype: >>> content = { ... 'thermal': , ... # certainty ONLY with `cosine` distance specified in the schema ... 'certainty': , # Optional, either 'certainty' OR 'distance' ... 'distance': , # Optional, either 'certainty' OR 'distance' ... } >>> { ... 'thermal': "e5dc4a4c-ef0f-3aed-89a3-a73435c6bbcf", ... 'certainty': 0.7 # or 'distance' ... } With `encoded` True: >>> content = { ... 'thermal': "my_thermal_path.png", ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('IMU')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=True) # <- encode MUST be set to True OR >>> my_thermal_file = open("my_thermal_path.png", "br") >>> content = { ... 'thermal': my_thermal_file, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('IMU')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=True) # <- encode MUST be set to True >>> my_thermal_file.close() With `encoded` False: >>> from weaviate.util import file_encoder_b64 >>> encoded_thermal = file_encoder_b64("my_thermal_path.png") >>> content = { ... 'thermal': encoded_thermal, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('IMU')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=False) # <- encode MUST be set to False OR >>> from weaviate.util import file_encoder_b64 >>> with open("my_thermal_path.png", "br") as my_thermal_file: ... encoded_thermal = file_encoder_b64(my_thermal_file) >>> content = { ... 'thermal': encoded_thermal, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('IMU')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=False) # <- encode MUST be set to False Encode IMU yourself: >>> import base64 >>> with open("my_thermal_path.png", "br") as my_thermal_file: ... encoded_thermal = base64.b64encode(my_thermal_file.read()).decode("utf-8") >>> content = { ... 'thermal': encoded_thermal, ... 'certainty': 0.7 # or 'distance' instead ... } >>> query = client.query.aggregate('IMU')\ ... .with_fields('description')\ ... .with_near_thermal(content, encode=False) # <- encode MUST be set to False Returns ------- weaviate.gql.aggregate.AggregateBuilder The updated AggregateBuilder. Raises ------ AttributeError If another 'near' filter was already set. rRT) rIMUrUr$rGrrZrr#rVs r) with_near_imuzAggregateBuilder.with_near_imuswL%== :: ! (  .>wtGWGWG]G]?^._GD$$** +W%   r*cZd|j}|jr|dz }|j|t|jz }|j%|dt j |jz }|j|t|jz }|jr|d|jz }|j|d|jdz }|j|d|jz }|dz }|d z }|jr|d z }|jD]}||z } |d z }|S) z Build the query and return the string. Returns ------- str The GraphQL query as a string. z {Aggregate{(z groupBy: z objectLimit: z tenant: ""zlimit: ){z meta{count}z}}}) rr#r!r/r"jsondumpsr$rr%r&rr )r'queryr:s r)buildzAggregateBuilder.buildWsE  0 012    SLE{{&T[[))((49TZZ0I0I%J$KLLzz%TZZ(!!=););(<==||'9T\\N!44{{&74;;-00 SLE    ] "E\\ E UNE   r*)r,r)T)__name__ __module__ __qualname____doc__r/rrr1r3intr7r9r=dictrArrDrHrJrOboolrWr[r_rbrerhrq __classcell__)r(s@r)rrs*3*J*0#*< s/A&(:$);&I$I+=IVtCy=O,OdO/AOb??1C?B001C0dotoToEWobptpTpEWpdptpTpEWpdptpTpEWpdootoGYobpTp4pCUpd(s(r*r)rurntypingrrweaviate.connectr weaviate.utilrrfilterr r r r r rrrrrrrrrr*r)rs< !'"bwbr*