Create index only if no exists

els/client.py

@@ -1,11 +1,22 @@
-import urllib.request
 import urllib.parse
+import urllib.request
+
 
 class ElsClient:
     def __init__(self, endpoint, index):
         self.endpoint = endpoint
         self.index = index
 
+    def get_index(self, index=None):
+        if not index: index = self.index
+
+        req = urllib.request.Request(
+                urllib.parse.urljoin(self.endpoint, "/" + self.index),
+                headers={'content-type': 'application/json'},
+                method="GET"
+                )
+        return self._request(req)
+
     def add_index(self, index_json_string, index=None):
         if not index: index = self.index
 

pukiwiki-crawler.py

@@ -1,24 +1,26 @@
-import urllib.parse
-import os
-from functools import reduce
-from datetime import date
-import time
 import argparse
-
-import json
 import glob
-import urllib.request
+import json
+import os
 import urllib.parse
-
-from els.client import ElsClient
+import urllib.request
+from urllib.error import HTTPError
 
 from config import pukiwiki as config
+from els.client import ElsClient
 
 client = ElsClient(config.ELASTIC_SEARCH_ENDPOINT, config.INDEX)
 
 def add_index(args):
-    with open(config.INDEX_FILE) as f:
-        print(client.add_index(f.read()).read().decode("utf-8"))
+    # Add index if not exists
+    try:
+        client.get_index()
+    except HTTPError as e:
+        if e.status == 404:
+            with open(config.INDEX_FILE) as f:
+                print(client.add_index(f.read()).read().decode("utf-8"))
+        else:
+            raise
 
 
 def delete_index(args):