Mysql
 sql >> डेटाबेस >  >> RDS >> Mysql

MySQL के साथ ElasticSearch को कैसे एकीकृत करें?

ES 5.x के अनुसार, उन्होंने लॉगस्टैश लगाना।

यह समय-समय पर डेटाबेस से डेटा आयात करेगा और ES सर्वर को पुश करेगा।

किसी को नीचे दी गई एक साधारण आयात फ़ाइल बनानी होती है (जिसे यहां ) और स्क्रिप्ट चलाने के लिए लॉगस्टैश का उपयोग करें। लॉगस्टैश इस स्क्रिप्ट को शेड्यूल पर चलाने का समर्थन करता है।

# file: contacts-index-logstash.conf
input {
    jdbc {
        jdbc_connection_string => "jdbc:mysql://localhost:3306/mydb"
        jdbc_user => "user"
        jdbc_password => "pswd"
        schedule => "* * * * *"
        jdbc_validate_connection => true
        jdbc_driver_library => "/path/to/latest/mysql-connector-java-jar"
        jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
        statement => "SELECT * from contacts where updatedAt > :sql_last_value"
    }
}
output {
    elasticsearch {
        protocol => http
        index => "contacts"
        document_type => "contact"
        document_id => "%{id}"
        host => "ES_NODE_HOST"
    }
}
# "* * * * *" -> run every minute
# sql_last_value is a built in parameter whose value is set to Thursday, 1 January 1970,
# or 0 if use_column_value is true and tracking_column is set

आप मावेन से MySQL जार डाउनलोड कर सकते हैं यहां

यदि यह स्क्रिप्ट निष्पादित होने पर ES में अनुक्रमणिका मौजूद नहीं है, तो वे स्वचालित रूप से बनाई जाएंगी। एक सामान्य पोस्ट की तरह, इलास्टिक्स खोज पर कॉल करें



  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. कैसे mysql में स्ट्रिंग का हिस्सा निकालने के लिए?

  2. सत्यनिष्ठा बाधा उल्लंघन:1048 कॉलम 'taggable_id' रिक्त नहीं हो सकता

  3. MySQL में UNHEX () फ़ंक्शन कैसे काम करता है

  4. MySQL डेटाबेस को ग्लासफ़िश क्लासपाथ से कनेक्ट करना सेट नहीं है या क्लासनाम गलत है

  5. Java.sql.DriverManager.getConnection(...) क्यों लटक रहा है?