theangryangel
commented
5 years ago You need one output per table, or you need to implement a stored procedure to do it for you.
If you’re getting an error, what is it?
Sent from my iPhone
On 6 Jun 2019, at 10:47, hlyaowan notifications@github.com wrote:
Hello, I want to use type to distinguish different tables to insert data, but the error is reported, how to support this writing, the detailed code is attached
eg:
output { stdout{ codec=>rubydebug{} } if [type]=="KBS_KEYWORD"{ jdbc { driver_jar_path => "/home/logstash/logstash-7.1.1/package/mysql-connector-java-5.1.21.jar" driver_class => "com.mysql.jdbc.Driver" connection_string => "jdbc:mysql://127.0.0.1:33066/botprod?user=botprod&password=LKHptq4GPOUUHZuZ1I1f" statement => [ "INSERT INTO KBS_KEYWORD_BAK (ID,ORG_ID,KEYWORD_NAME,KEYWORD_PINYIN,ABBREV,SYNONYMS,NEAR,TYPOS,HYPERNYM,HYPONYM,RELATED,DOMAIN,TYPE,DEFINITION,SCORE,WEIGHT,SENSITIVITY,POPULARITY,ENABLED,CREATION_DATE,CREATOR,MODIFICATION_DATE,MODIFIER) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE ORG_ID =values(ORG_ID),KEYWORD_NAME =values(KEYWORD_NAME),KEYWORD_PINYIN =values(KEYWORD_PINYIN),ABBREV =values(ABBREV),SYNONYMS =values(SYNONYMS),NEAR =values(NEAR),TYPOS =values(TYPOS),HYPERNYM =values(HYPERNYM),HYPONYM =values(HYPONYM),RELATED =values(RELATED),DOMAIN =values(DOMAIN),TYPE =values(TYPE),DEFINITION =values(DEFINITION),SCORE =values(SCORE),WEIGHT =values(WEIGHT),SENSITIVITY =values(SENSITIVITY),POPULARITY =values(POPULARITY),ENABLED =values(ENABLED),CREATION_DATE =values(CREATION_DATE),CREATOR =values(CREATOR),MODIFICATION_DATE =values(MODIFICATION_DATE),MODIFIER =values(MODIFIER)", "ID","ORG_ID","KEYWORD_NAME","KEYWORD_PINYIN","ABBREV","SYNONYMS","NEAR","TYPOS","HYPERNYM","HYPONYM","RELATED","DOMAIN","TYPE","DEFINITION","SCORE","WEIGHT","SENSITIVITY","POPULARITY","ENABLED","CREATION_DATE","CREATOR","MODIFICATION_DATE","MODIFIER" ] } }
if [type]=="KBS_CATEGORY"{ jdbc { driver_jar_path => "/home/logstash/logstash-7.1.1/package/mysql-connector-java-5.1.36.jar" driver_class => "com.mysql.jdbc.Driver" connection_string => "jdbc:mysql://127.0.0.1:33066/botprod?user=botprod&password=LKHptq4GPOUUHZuZ1I1f" statement => [ "INSERT INTO KBS_CATEGORY_BAK (ID,ORG_ID,NAME,PARENT_ID,ENABLED,CREATION_DATE,CREATOR,MODIFICATION_DATE,MODIFIER) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE ORG_ID =values(ORG_ID),NAME =values(NAME),PARENT_ID =values(PARENT_ID),ENABLED =values(ENABLED),CREATION_DATE =values(CREATION_DATE),CREATOR =values(CREATOR),MODIFICATION_DATE =values(MODIFICATION_DATE),MODIFIER =values(MODIFIER)","ID","ORG_ID","NAME","PARENT_ID","ENABLED","CREATION_DATE","CREATOR","MODIFICATION_DATE","MODIFIER" ] } }
}
— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub, or mute the thread.
hlyaowan
stale[bot]
Hello, I want to use type to distinguish different tables to insert data, but the error is reported, how to support this writing, the detailed code is attached
eg:
output { stdout{ codec=>rubydebug{} } if [type]=="KBS_KEYWORD"{ jdbc { driver_jar_path => "/home/logstash/logstash-7.1.1/package/mysql-connector-java-5.1.21.jar" driver_class => "com.mysql.jdbc.Driver" connection_string => "jdbc:mysql://127.0.0.1:33066/botprod?user=botprod&password=LKHptq4GPOUUHZuZ1I1f" statement => [ "INSERT INTO KBS_KEYWORD_BAK (ID,ORG_ID,KEYWORD_NAME,KEYWORD_PINYIN,ABBREV,SYNONYMS,NEAR,TYPOS,HYPERNYM,HYPONYM,RELATED,DOMAIN,TYPE,DEFINITION,SCORE,WEIGHT,SENSITIVITY,POPULARITY,ENABLED,CREATION_DATE,CREATOR,MODIFICATION_DATE,MODIFIER) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE ORG_ID =values(ORG_ID),KEYWORD_NAME =values(KEYWORD_NAME),KEYWORD_PINYIN =values(KEYWORD_PINYIN),ABBREV =values(ABBREV),SYNONYMS =values(SYNONYMS),NEAR =values(NEAR),TYPOS =values(TYPOS),HYPERNYM =values(HYPERNYM),HYPONYM =values(HYPONYM),RELATED =values(RELATED),DOMAIN =values(DOMAIN),TYPE =values(TYPE),DEFINITION =values(DEFINITION),SCORE =values(SCORE),WEIGHT =values(WEIGHT),SENSITIVITY =values(SENSITIVITY),POPULARITY =values(POPULARITY),ENABLED =values(ENABLED),CREATION_DATE =values(CREATION_DATE),CREATOR =values(CREATOR),MODIFICATION_DATE =values(MODIFICATION_DATE),MODIFIER =values(MODIFIER)", "ID","ORG_ID","KEYWORD_NAME","KEYWORD_PINYIN","ABBREV","SYNONYMS","NEAR","TYPOS","HYPERNYM","HYPONYM","RELATED","DOMAIN","TYPE","DEFINITION","SCORE","WEIGHT","SENSITIVITY","POPULARITY","ENABLED","CREATION_DATE","CREATOR","MODIFICATION_DATE","MODIFIER" ] } }
if [type]=="KBS_CATEGORY"{ jdbc { driver_jar_path => "/home/logstash/logstash-7.1.1/package/mysql-connector-java-5.1.36.jar" driver_class => "com.mysql.jdbc.Driver" connection_string => "jdbc:mysql://127.0.0.1:33066/botprod?user=botprod&password=LKHptq4GPOUUHZuZ1I1f" statement => [ "INSERT INTO KBS_CATEGORY_BAK (ID,ORG_ID,NAME,PARENT_ID,ENABLED,CREATION_DATE,CREATOR,MODIFICATION_DATE,MODIFIER) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE ORG_ID =values(ORG_ID),NAME =values(NAME),PARENT_ID =values(PARENT_ID),ENABLED =values(ENABLED),CREATION_DATE =values(CREATION_DATE),CREATOR =values(CREATOR),MODIFICATION_DATE =values(MODIFICATION_DATE),MODIFIER =values(MODIFIER)","ID","ORG_ID","NAME","PARENT_ID","ENABLED","CREATION_DATE","CREATOR","MODIFICATION_DATE","MODIFIER" ] } }
}