php – Elasticsearch – 我需要JDBC驱动程序吗?
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了php – Elasticsearch – 我需要JDBC驱动程序吗?,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含2072字,纯文字阅读大概需要3分钟。
内容图文
![php – Elasticsearch – 我需要JDBC驱动程序吗?](/upload/InfoBanner/zyjiaocheng/818/e135d40b20864dedbc953dcbcbb3e3b7.jpg)
目标
将我的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之间同步数据,每种选项的优缺点是什么.是否有一个特定的用例定义使用一个而不是另一个?
解决方法:
如果您忘记了需要将初始数据导入Elasticsearch,我会使用事件系统将数据推送到Elasticsearch.从长远来看,这更有效.
您的应用程序确切知道Elasticsearch何时需要索引某些内容.要获取您的推文示例,在某个时刻,新的推文将进入您的应用程序(例如,用户编写一个).这将触发newTweet事件.你有一个监听器来监听那个事件,并在调度这样的事件时将推文存储在Elasticsearch中.
如果您不想在Web请求中使用资源/时间来执行此操作(并且您肯定不希望这样做),则侦听器可以将作业添加到队列(例如,Gearman或Beanstalkd).然后,您需要一个能够选择该工作并将该推文存储在Elasticsearch中的工作人员.
主要优点是Elasticsearch能够更加实时地保持最新状态.你不需要一个会引入延迟的cronjob.您(大部分)一次处理一个文档.您不需要打扰SQL数据库来找出需要(重新)索引的内容.
另一个优点是,当事件/数据量失控时,您可以轻松扩展.当Elasticsearch本身需要更多功能时,请将服务器添加到群集中.当工人无法处理负载时,只需添加更多负载(并将它们放在专用机器上).另外,您的网络服务器和SQL数据库也不会有任何感觉.
内容总结
以上是互联网集市为您收集整理的php – Elasticsearch – 我需要JDBC驱动程序吗?全部内容,希望文章能够帮你解决php – Elasticsearch – 我需要JDBC驱动程序吗?所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。