busqueda/funko.cr

@@ -1,6 +1,5 @@
 require "json"
 require "kemal"
-require "db"
 require "pg"
 require "pool/connection"
 
@@ -12,6 +11,11 @@ DBHOST = File.read("/secrets/dbhost").strip
 DBURL = "postgres://#{USER}:#{PASS}@#{DBHOST}:5432/nombres"
 puts "Connnecting to #{DBURL}"
 
+# Create a connection pool to the database
+pg = ConnectionPool.new(capacity: 5, timeout: 1.seconds) do
+  PG.connect(DBURL)
+end
+
 def normalize(s : String) : String
   s.unicode_normalize(:nfkd)
     .chars.reject! { |character|
@@ -21,7 +25,6 @@ end
 
 # A basic hello world get endpoint
 post "/" do |env|
-  db = DB.open DBURL
   prefijo = env.params.json["p"].as(String)
   genero = env.params.json["g"].as(String)
   year = env.params.json["a"].as(String)
@@ -32,33 +35,34 @@ post "/" do |env|
   end
   datos = [] of Tuple(String, Int32 | String)
   # Connect using credentials provided
-  if prefijo.empty? && year.empty?
-    result_set = db.query("
+  pg.connection do |cursor|
+    if prefijo.empty? && year.empty?
+      result_set = cursor.query("
         SELECT nombre, total::integer
         FROM totales
         ORDER BY total DESC
         LIMIT 50")
-  elsif prefijo.empty? && !year.empty?
-    # Per-year totals
-    result_set = db.query("
+    elsif prefijo.empty? && !year.empty?
+      # Per-year totals
+      result_set = cursor.query("
         SELECT nombre, contador::integer
         FROM nombres
         WHERE
           anio = $1
         ORDER BY contador DESC
         LIMIT 50", year)
-  elsif !prefijo.empty? && year.empty?
-    # Filter only by prefix
-    result_set = db.query("
+    elsif !prefijo.empty? && year.empty?
+      # Filter only by prefix
+      result_set = cursor.query("
         SELECT nombre, total::integer
         FROM totales
         WHERE
             nombre LIKE $1
         ORDER BY total DESC
         LIMIT 50", prefijo + "%")
-  elsif !prefijo.empty? && !year.empty?
-    # We have both
-    result_set = db.query("
+    elsif !prefijo.empty? && !year.empty?
+      # We have both
+      result_set = cursor.query("
         SELECT nombre, contador::integer
         FROM nombres
         WHERE
@@ -66,19 +70,20 @@ post "/" do |env|
             nombre LIKE $2
         ORDER BY contador DESC
         LIMIT 50", year, prefijo + "%")
-  end
-
-  if !result_set.nil?
-    result_set.each do
-      nombre = result_set.read(String)
-      valor = result_set.read(Int32)
-      datos.push({nombre, valor})
     end
-    result_set.close
-  end
 
-  if datos.empty?
-    raise "No data found"
+    if !result_set.nil?
+      result_set.each do
+        nombre = result_set.read(String)
+        valor = result_set.read(Int32)
+        datos.push({nombre, valor})
+      end
+      result_set.close
+    end
+
+    if datos.empty?
+      raise "No data found"
+    end
   end
   # In this context, remove all composite names
   datos.reject! { |row|
@@ -87,37 +92,39 @@ post "/" do |env|
   datos.insert(0, {"Nombre", "Cuantos?"})
 
   if genero
-    datos.reject! { |row|
-      # How feminine is this name?
-      # Yes this database is upper case
-      puts "Checking #{row[1]} #{row[0]}"
-      feminidad = 0
-      sql = %(
+    pg.connection do |cursor|
+      datos.reject! { |row|
+        # How feminine is this name?
+        # Yes this database is upper case
+        puts "Checking #{row[1]} #{row[0]}"
+        feminidad = 0
+        sql = %(
             SELECT COALESCE((SELECT frecuencia FROM mujeres WHERE nombre='#{row[0]?.to_s.upcase}'), 0) AS mujeres,
                    COALESCE((SELECT frecuencia FROM hombres WHERE nombre='#{row[0]?.to_s.upcase}'), 0) AS hombres
           )
-      puts "SQL: #{sql}"
-      db.query sql do |result_set|
-        result_set.each do
-          mujeres = result_set.read(Int32)
-          hombres = result_set.read(Int32)
-          puts "frecuencias: #{mujeres} #{hombres}"
-          if hombres == mujeres == 0
-            feminidad = 0.5
-          else
-            feminidad = mujeres / (hombres + mujeres)
+        puts "SQL: #{sql}"
+        cursor.query sql do |result_set|
+          result_set.each do
+            mujeres = result_set.read(Int32)
+            hombres = result_set.read(Int32)
+            puts "frecuencias: #{mujeres} #{hombres}"
+            if hombres == mujeres == 0
+              feminidad = 0.5
+            else
+              feminidad = mujeres / (hombres + mujeres)
+            end
           end
         end
-      end
-      # El overlap en 0.5 es intencional!
-      if (feminidad >= 0.5 && genero == "f") ||
-         (feminidad <= 0.5 && genero == "m")
-        false
-      else
-        true
-      end
-    }
-    puts "Data split by gender"
+        # El overlap en 0.5 es intencional!
+        if (feminidad >= 0.5 && genero == "f") ||
+           (feminidad <= 0.5 && genero == "m")
+          false
+        else
+          true
+        end
+      }
+      puts "Data split by gender"
+    end
   end
   datos = datos[..10].map { |row|
     [row[0].capitalize, row[1]]
@@ -134,14 +141,9 @@ post "/" do |env|
     "title" => title,
     "data"  => datos,
   }.to_json
-ensure
-  db.try &.close
 end
 
 get "/ping/" do
-  db = DB.open DBURL
-  db.exec("SELECT 42")
+  pg.connection.exec("SELECT 42")
   "OK"
-ensure
-  db.try &.close
 end

deploy.sh

@@ -1,6 +1,6 @@
 #!/bin/sh -x
 set -e
-export OPENFAAS_URL=http://pinky:8082
+#export OPENFAAS_URL=http://pinky:8082
 #pass faas.ralsina.me | faas-cli login -u admin --password-stdin
 
 #pass iol-pass | faas-cli secret create iol-pass
@@ -14,18 +14,15 @@ export FAASO_SERVER=http://rocky:8888/admin
 pass faaso-rocky | faaso login
 pass nombres-user | faaso secret -a historico user
 pass nombres-pass | faaso secret -a historico pass
-echo "rocky.tail20c16.ts.net"      | faaso secret -a historico dbhost 
+echo "192.168.0.98"      | faaso secret -a historico dbhost 
 faaso build busqueda
 faaso scale busqueda 0
 faaso scale busqueda 1
 pass nombres-user | faaso secret -a busqueda user
 pass nombres-pass | faaso secret -a busqueda pass
-echo "rocky.tail20c16.ts.net"      | faaso secret -a busqueda dbhost 
+echo "192.168.0.98"      | faaso secret -a busqueda dbhost 
 faaso build historico
 faaso scale historico 0
 faaso scale historico 1
-rsync -rav nombres.ralsina.me/* ralsina@rocky:/data/stacks/web/websites/nombres.ralsina.me/
 
-faaso build tapas
-faaso scale tapas 0
-faaso scale tapas 1
+rsync -rav nombres.ralsina.me/* ralsina@pinky:/data/websites/nombres.ralsina.me/

functions.yml

@@ -3,6 +3,10 @@ provider:
   name: openfaas
   gateway: http://pinky:8082
 functions:
+  tapas:
+    lang: python3-flask
+    handler: ./tapas
+    image: ralsina/tapas:latest
   iol:
     lang: python3-fastapi
     handler: ./iol

historico/funko.cr

@@ -11,6 +11,11 @@ DBHOST = File.read("/secrets/dbhost").strip
 DBURL = "postgres://#{USER}:#{PASS}@#{DBHOST}:5432/nombres"
 puts "Connnecting to #{DBURL}"
 
+# Create a connection pool to the database
+pg = ConnectionPool.new(capacity: 5, timeout: 1.seconds) do
+  PG.connect(DBURL)
+end
+
 # Connect to the database and get information about
 # the requested names
 get "/" do |env|
@@ -26,7 +31,7 @@ get "/" do |env|
     results << [anio.to_s]
   end
   # Connect using credentials provided
-  db = DB.open DBURL
+  pg.connection do |cursor|
     # Get the information for each name
     names.map do |name|
       # Normalize: remove diacritics etc.
@@ -36,7 +41,7 @@ get "/" do |env|
       }.join("").downcase
 
       counter_per_year = {} of Int32 => Int32
-      db.query("
+      cursor.query("
       SELECT anio::integer, contador::integer
         FROM nombres WHERE nombre = $1", name) do |result_set|
         result_set.each do
@@ -47,15 +52,15 @@ get "/" do |env|
         results[anio - 1921] << counter_per_year.fetch(anio, 0).to_s
       end
     end
+  end
   results.to_json
-ensure
-  db.try &.close
 end
 
+# The `/ping/` endpoint is configured in the container as a healthcheck
+# You can make it better by checking that your database is responding
+# or whatever checks you think are important
+#
 get "/ping/" do
-  db = DB.open DBURL
-  db.exec("SELECT 42")
+  pg.connection.exec("SELECT 42")
   "OK"
-ensure
-  db.try &.close
 end

nombres.ralsina.me/index.html

@@ -306,7 +306,6 @@
           id="nombres"
           placeholder="Nombres separados con comas"
           aria-label="Search"
-	        value="juan,maria"
         />
         <input type="submit" value="Buscar" onCLick="drawChart2();" />
       </form>

tapas/funko.yml

@@ -1,18 +0,0 @@
-name: tapas
-runtime: flask
-options:
-  ship_packages: 
-    - jpeg
-    - zlib
-    - freetype
-  devel_packages:
-    - zlib-dev
-    - jpeg-dev
-    - freetype-dev
-  healthcheck_options: "--interval=1m --timeout=2s --start-period=2s --retries=3"
-  healthcheck_command: "curl --fail http://localhost:3000/ping || exit 1"
-  copy_from_build:
-    - "static static"
-    - "venv venv"
-    - "run.sh ."
-    - "funko.py ."

tapas/handler.py

@@ -1,12 +1,10 @@
-from flask import Flask, request
+from json import loads
 from tapita import Cover
 from io import BytesIO
 import base64
 
-app = Flask("tapas")
 
-@app.route('/', methods=['POST'])
-def handle():
+def handle(req):
     """handle a request to the function
     Args:
         req (str): request body
@@ -17,10 +15,10 @@ def handle():
         "author": "bat",
     }
     """
-    if not request:
+    if not req:
         return "Foo", 200, {"Content-Type": "text/plain"}
     try:
-        args = request.json
+        args = loads(req)
     except Exception:
         return "Bad Request", 400
 
@@ -33,9 +31,3 @@ def handle():
         200,
         {"Content-Type": "text/html"},
     )
-
-@app.route('/ping')
-def ping():
-    return "OK"
-
-

tapas/requirements.txt

@@ -1,2 +1 @@
-flask
 tapita

tapas/run.sh

@@ -1,2 +0,0 @@
-#!/bin/sh
-uwsgi  --plugins http,python -H venv --http 0.0.0.0:3000 --master -p 1 -w funko:app