fluent/fluent-plugin-sql

Plugin not working for snowflake but works for mysql

RAJMODI038 opened this issue · 0 comments

Does this plugin support Snowflake? I tried with MySQL and it's working perfectly. But with snowflake, it's giving error:
[error]: #0 Could not load the 'snowflake' Active Record adapter. Ensure that the adapter is spelled correctly in config/database.yml and that you've added the necessary adapter gem to your Gemfile.
It seems there's something wrong with the adapter/adapter name.
I'm using docker for fluentd.
Dockerfile:

FROM fluent/fluentd:v1.15.3-debian-1.0
USER root
RUN ["fluent-gem", "install", "fluent-plugin-sql"]
RUN apt-get update && \
    apt-get -y install make && \
    apt-get -y install unixodbc-dev
RUN ["fluent-gem", "install", "sequel-snowflake"]
USER fluent

Conf:

  <match>
    @type sql
    adapter snowflake
    host my_org.snowflakecomputing.com
    port 443
    database PROD
    username <username>
    password <password>
    <table>
      table <schema>.EVENTS_TEST
      column_mapping 'name:name,value:value,labels:labels,type:type'
    </table>
  </match>

I've also tried adapter :snowflake as mentioned in https://github.com/Yesware/sequel-snowflake