目标

要将我的Elasticsearch服务器与SQL数据库中的新数据和过期数据同步

问题

我可以通过两种非常不同的方式来实现这一目标，但我不知道哪种更好。我可以使用JDBC river插件通过直接连接到SQL数据库的方式 将 信息
拉 入elasticsearch。另外，我可以使用下面的代码作为示例，使用PHP客户端 将 数据 推
送到elasticsearch：

// The Id of the document
$id = 1;

// Create a document
$tweet = array(
    'id'      => $id,
    'user'    => array(
        'name'      => 'mewantcookie',
        'fullName'  => 'Cookie Monster'
    ),
    'msg'     => 'Me wish there were expression for cookies like there is for apples. "A cookie a day make the doctor diagnose you with diabetes" not catchy.',
    'tstamp'  => '1238081389',
    'location'=> '41.12,-71.34',
    '_boost'  => 1.0
);
// First parameter is the id of document.
$tweetDocument = new \Elastica\Document($id, $tweet);

// Add tweet to type
$elasticaType->addDocument($tweetDocument);

// Refresh Index
$elasticaType->getIndex()->refresh();

我打算每30分钟运行一次cron，以检查数据库中不仅有“活动”标志而且没有“索引”标志的项目，这意味着我需要将它们添加到索引中。

题

看来我有两种方法可以通过两种不同方式在elasticsearch和mysql之间同步数据，每种选择的优点和缺点是什么。是否有一个特定的用例定义了一个使用？