feat(python): guides

Author: Fluf22

templates/python/guides/ingestion/pushSetup.mustache

@@ -1,9 +1,8 @@
-import asyncio
 import json
 {{> snippets/import}}
 
 
-async def main():
+if __name__ == '__main__':
     # use the region matching your applicationID
     _{{> snippets/init}}
 
@@ -14,5 +13,3 @@ async def main():
         resp = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
 
         print(resp)
-
-asyncio.run(main())

templates/python/guides/search/deleteMultipleIndices.mustache

@@ -1,8 +1,7 @@
-import asyncio
 {{> snippets/import}}
 
 
-async def main():
+if __name__ == '__main__':
   try:
     # You need an API key with `deleteIndex`
     _{{> snippets/init}}
@@ -29,4 +28,3 @@ async def main():
   except Exception as e:
     print(f"Error: {e}")
 
-asyncio.run(main())

templates/python/guides/search/saveObjectsChunks.mustache

@@ -0,0 +1,21 @@
+import json
+
+{{> snippets/import}}
+
+
+if __name__ == '__main__':
+  try:
+    _{{> snippets/init}}
+
+    with open("records.json", "r", encoding="utf-8") as f:
+      records = json.load(f)
+
+      chunk_size = 10000
+
+      for begin_index in range(0, len(records), chunk_size):
+        chunk = records[begin_index:begin_index + chunk_size]
+        {{#dynamicSnippet}}saveObjectsChunks{{/dynamicSnippet}}
+
+  except Exception as e:
+    print(f"Error: {e}")
+

templates/python/guides/search/saveObjectsMCM.mustache

@@ -0,0 +1,19 @@
+{{> snippets/import}}
+
+def _get_all_app_id_configurations():
+    return [] # A list of your MCM AppID/ApiKey pairs
+
+if __name__ == '__main__':
+  playlists = [] # Your records
+
+  # Fetch from your own data storage and with your own code
+  # the list of application IDs and API keys to target each cluster
+  configurations = _get_all_app_id_configurations()
+
+  # Send the records to each cluster
+  for appID, apiKey in configurations:
+    try:
+      _client = SearchClientSync(appID, apiKey)
+      {{#dynamicSnippet}}saveObjectsPlaylists{{/dynamicSnippet}}
+    except Exception as e:
+        print(f"Error: {e}")

templates/python/guides/search/saveObjectsModified.mustache

@@ -0,0 +1,29 @@
+import json
+
+{{> snippets/import}}
+
+
+if __name__ == '__main__':
+  try:
+      _{{> snippets/init}}
+
+      with open("products.json", "r", encoding="utf-8") as f:
+          products = json.load(f)
+
+          records = []
+
+          for product in products:
+              reference = product['product_reference']
+
+              suffixes = []
+              while len(reference) > 1:
+                  reference = reference[1:]
+                  suffixes.append(reference)
+
+              product['product_reference_suffixes'] = suffixes
+              records.append(product)
+
+      {{#dynamicSnippet}}saveObjectsRecords{{/dynamicSnippet}}
+  except Exception as e:
+      print(f"Error: {e}")
+

templates/python/guides/search/saveObjectsMovies.mustache

@@ -1,9 +1,8 @@
-import asyncio
 import requests
 {{> snippets/import}}
 
 
-async def main():
+if __name__ == '__main__':
     # Fetch sample dataset
     url = "https://dashboard.algolia.com/api/1/sample_datasets?type=movie"
     movies = requests.get(url).json()
@@ -13,5 +12,3 @@ async def main():
 
     # Save records in Algolia index
     {{#dynamicSnippet}}saveObjectsMovies{{/dynamicSnippet}}
-
-asyncio.run(main())

templates/python/guides/search/saveObjectsPublicUser.mustache

@@ -0,0 +1,12 @@
+{{> snippets/import}}
+
+
+if __name__ == '__main__':
+  playlists = [] # Your records
+
+  try:
+    _{{> snippets/init}}
+
+    {{#dynamicSnippet}}saveObjectsPlaylistsWithUserIDPublic{{/dynamicSnippet}}
+  except Exception as e:
+    print(f"Error: {e}")

templates/python/guides/search/savePopularRecords.mustache

@@ -0,0 +1,26 @@
+{{> snippets/import}}
+from algoliasearch.search.models.browse_response import BrowseResponse
+
+
+if __name__ == '__main__':
+  try:
+    _{{> snippets/init}}
+
+    records = []
+    def _aggregator(resp: BrowseResponse):
+      for hit in resp.hits:
+        hit_dict = hit.to_dict()
+        records.append({
+          'twitterHandle': hit_dict['twitterHandle'],
+          'nbFollowers': hit_dict['nbFollowers'],
+          'isPopular': hit_dict['nbFollowers'] > 1000000,
+        })
+
+    _client.browse_objects(
+      index_name="<YOUR_INDEX_NAME>",
+      aggregator=_aggregator,
+    )
+
+    {{#dynamicSnippet}}saveObjectsRecords{{/dynamicSnippet}}
+  except Exception as e:
+    print(f"Error: {e}")

templates/python/guides/search/searchRecentlyPublishedBooks.mustache

@@ -0,0 +1,18 @@
+import time
+
+{{> snippets/import}}
+
+
+if __name__ == '__main__':
+  try:
+    _{{> snippets/init}}
+
+    date_timestamp = time.time()  # Get current timestamp
+    search_params = {
+        "query": "<YOUR_SEARCH_QUERY>",
+        "filters": f"date_timestamp > {date_timestamp}"
+    }
+
+    {{#dynamicSnippet}}searchWithSearchParams{{/dynamicSnippet}}
+  except Exception as e:
+    print(f"Error: {e}")

templates/python/guides/search/searchWithGAToken.mustache

@@ -0,0 +1,26 @@
+{{> snippets/import}}
+
+
+def _get_google_analytics_user_id_from_browser_cookie(cookie_name: str) -> str:
+    # Implement your logic here
+    return ''
+
+if __name__ == '__main__':
+  try:
+    _{{> snippets/init}}
+
+    user_token = _get_google_analytics_user_id_from_browser_cookie('_ga')
+    search_params = {
+      'query': '<YOUR_SEARCH_QUERY>',
+      'userToken': user_token,
+    }
+
+    {{#dynamicSnippet}}searchWithSearchParams{{/dynamicSnippet}}
+
+    logged_in_user = None
+
+    search_params['user_token'] = logged_in_user or user_token
+
+    {{#dynamicSnippet}}searchWithSearchParams{{/dynamicSnippet}}
+  except Exception as e:
+    print(f"Error: {e}")