Anko

Anko

Table.Reader for Elasticsearch isn't working :(

I’m trying to write a Table.Reader implementation for Snap.SearchResponse from the snap library (GitHub - breakroom/snap: An Elasticsearch client for Elixir) which talks to elasticsearch

This is what I think it should look like

if Code.ensure_loaded?(Table.Reader) do
  defimpl Table.Reader, for: Snap.SearchResponse do
    def init(result) do
      columns = get_columns(result)
      rows = get_rows(result)
      {:rows, %{columns: columns}, rows}
    end

    defp get_columns(response) do
      if response.hits.hits |> Enum.empty?() do
        []
      else
        hits = response.hits.hits
        hits |> List.first() |> Map.fetch!(:source) |> Map.keys()
      end
    end

    defp get_rows(response) do
      hits = response.hits.hits

      hits
      |> Enum.map(fn hit ->
        hit.source |> Map.values()
      end)
    end
  end
end

and here is an Example Snap.SearchResponse

%Snap.SearchResponse{
  took: 1,
  timed_out: false,
  shards: %{"failed" => 0, "skipped" => 0, "successful" => 1, "total" => 1},
  hits: %Snap.Hits{
    total: %{"relation" => "gte", "value" => 10000},
    max_score: 1.0,
    hits: [
      %Snap.Hit{
        index: "products",
        type: nil,
        id: "BH2lkY0BtfUXFCo5NxOU",
        score: 1.0,
        source: %{
          "Country" => "Myanmar",
          "Item Type" => "Beverages",
          "Order Date" => "5/29/2016",
          "Order ID" => "238846909",
          "Order Priority" => "L",
          "Region" => "Asia",
          "Sales Channel" => "Offline",
          "Ship Date" => "6/15/2016",
          "Total Cost" => "284933.77",
          "Total Profit" => "140360.58",
          "Total Revenue" => "425294.35",
          "Unit Cost" => "31.79",
          "Unit Price" => "47.45",
          "Units Sold" => "8963"
        },
        fields: nil,
        explanation: nil,
        matched_queries: nil,
        highlight: nil,
        inner_hits: nil
      },
      %Snap.Hit{
        index: "products",
        type: nil,
        id: "BX2lkY0BtfUXFCo5NxOU",
        score: 1.0,
        source: %{
          "Country" => "Costa Rica",
          "Item Type" => "Cereal",
          "Order Date" => "2/23/2017",
          "Order ID" => "673583209",
          "Order Priority" => "L",
          "Region" => "Central America and the Caribbean",
          "Sales Channel" => "Online",
          "Ship Date" => "2/26/2017",
          "Total Cost" => "830895.45",
          "Total Profit" => "628546.05",
          "Total Revenue" => "1459441.50",
          "Unit Cost" => "117.11",
          "Unit Price" => "205.70",
          "Units Sold" => "7095"
        },
        fields: nil,
        explanation: nil,
        matched_queries: nil,
        highlight: nil,
        inner_hits: nil
      },
      %Snap.Hit{
        index: "products",
        type: nil,
        id: "Bn2lkY0BtfUXFCo5NxOU",
        score: 1.0,
        source: %{
          "Country" => "Cameroon",
          "Item Type" => "Meat",
          "Order Date" => "7/30/2014",
          "Order ID" => "277272450",
          "Order Priority" => "H",
          "Region" => "Sub-Saharan Africa",
          "Sales Channel" => "Offline",
          "Ship Date" => "8/12/2014",
          "Total Cost" => "3623195.15",
          "Total Profit" => "568282.00",
          "Total Revenue" => "4191477.15",
          "Unit Cost" => "364.69",
          "Unit Price" => "421.89",
          "Units Sold" => "9935"
        },
        fields: nil,
        explanation: nil,
        matched_queries: nil,
        highlight: nil,
        inner_hits: nil
      },
      %Snap.Hit{
        index: "products",
        type: nil,
        id: "B32lkY0BtfUXFCo5NxOU",
        score: 1.0,
        source: %{
          "Country" => "Republic of the Congo",
          "Item Type" => "Clothes",
          "Order Date" => "9/23/2015",
          "Order ID" => "593713462",
          "Order Priority" => "H",
          "Region" => "Sub-Saharan Africa",
          "Sales Channel" => "Online",
          "Ship Date" => "10/7/2015",
          "Total Cost" => "66734.08",
          "Total Profit" => "136745.28",
          "Total Revenue" => "203479.36",
          "Unit Cost" => "35.84",
          "Unit Price" => "109.28",
          "Units Sold" => "1862"
        },
        fields: nil,
        explanation: nil,
        matched_queries: nil,
        highlight: nil,
        inner_hits: nil
      }
    ]
  },
  suggest: nil,
  aggregations: nil,
  scroll_id: nil,
  pit_id: nil
}

so i’ve forked snap, added this code and loaded it in a livebook

{:ok, results} = Snap.Search.search(Elastic, "products", %{query: %{match_all: %{}}})

results

I would expect livebook to show me a data table, but instead it just shows me the full Snap.SearchResponse pasted above. I have tried added IO.puts in the Table.Reader init function but to no avail. Any ideas how i can debug this?

Marked As Solved

jonatanklosko

jonatanklosko

Creator of Livebook

In order for Livebook to render a struct in a special way, it needs to implement the Kino.Render protocol. See kino_db/lib/kino_db.ex at 0de094fcefb2f28a5c413e95ce551adf00dcb5e7 · livebook-dev/kino_db · GitHub for example.

Where Next?

Popular in Questions Top

greenz1
I have a phoenix application from which a user can download multiple(5-6) files of size 1MB. I couldn’t find anything related to sending ...
New
electic
Hi, I am new to Elixir. I am trying to use the DateTime component to insert a date into MySQL however the there seems to be no way to fo...
New
pmjoe
I have a relationship of love and hate with Elixir. Lots of things are just absolutely right, but there are some things that are kind of ...
New
vrod
I am using the Starship cross-shell prompt – it seems pretty nice, but I get some errors: [WARN] - (starship::utils): Executing command ...
New
alice
Hey, Just curious what are the main benefits of Elixir compared to Clojure? When is Elixir more useful than Clojure and vice versa? Th...
New
jay1
Why is it that the mnesia database isn’t the most preferred database for use in Elixir/Phoenix?
New
nobody
Hi! In PHP: $SERVER['SERVERADDR'] - in Elixir? Searched the docs for ip address and the web, no good results. Thanks!
New
dblack
I’ve got an issue with an app and I’ve no idea of how to troubleshoot it. I’m hoping someone here might have seen something similar. I p...
New
sergio_101
I am VERY much an elixir newbie. I have taken one elixir course and one phoenix course on Udemy. During that course, I saw the instructor...
New
JDanielMartinez
Hi! May someone helps me, please! I have two apps into an umbrella project: the first one is Database, which manages queries, and the se...
New

Other popular topics Top

vertexbuffer
Hello, can anybody help here..? I have a list of players and I what to delete an element, but every for loop the list is reverting to ori...
New
Darmani72
If I have a post route which an argument: post /my_post_route/:my_param1, MyController.my_post_handler How would get the post params ...
New
JakeBecker
TL;DR: I’ve just released an implementation of Microsoft’s IDE-independent Language Server Protocol for Elixir. It adds language support ...
1144 53578 245
New
Emily
I have VueJS GUIs with the project generated using Webpack. I have Elixir modules that will need to be used by the VueJS GUIs. I fore...
New
jerry
Good day to you all. I have been struggling to get a query involving like and ilike to work. Can anyone assist me on this, please? pro...
New
baxterw3b
Hi guys, i’m new in the Elixir world, and i have to say, that i love it! i’m having some problem to understand anonymous functions with ...
New
ashish173
I am using Ecto timestamps with postgres, I can see the timestamps() use the :naive_dateime but for my use case I wanted to store the ti...
New
romenigld
I am trying to run a deploy with docker and I successfully runned with this command: docker build -t romenigld/blog-prod . but when I t...
New
PeterCarter
There are pre-rolled solutions for other frameworks that do work. However, Phoenix does not seem to have these. Have people had good expe...
New
sergio
Kind of like when jquery came out, it was super necessary. Existing drag and drop libraries have a bunch of baggage to support old browse...
New

We're in Beta

About us Mission Statement