tranquility

Tranquillité

«Restez près, mes amis et je guérirai vos blessures.»
—Mythen of the Wild

Tranquility vous aide à envoyer des flux d'événements à Druid, le magasin de données RADDORSE JAMAIS (http://druid.io/), en temps réel. Il gère le partitionnement, la réplication, la découverte de services et le roulement de schéma pour vous, de manière transparente et sans temps d'arrêt. La tranquillité est écrite à Scala et Bundles Idiomatic Java et Scala API qui fonctionnent bien avec Finagle, Samza, Spark, Storm et Trident.

Ce projet est un ami de Druid. Pour la discussion, n'hésitez pas à utiliser les canaux druides normaux: http://druid.io/community/

Documentation

Général:

• Aperçu - Introduction aux concepts de tranquillité, y compris des détails sur la façon dont il crée et gère les tâches druides.
• Configuration - La première étape de l'utilisation de la transfert est de la configurer de manière appropriée pour votre source de données Druid. Cela se fait généralement via un fichier de configuration, avec des raffinements facultatifs dans le code.
• Dépannage - Solutions aux problèmes communs.

Modules:

• Core - L'API la plus élémentaire de données. Vous utiliserez probablement celui-ci à moins que vous n'utilisiez l'un des modules de niveau supérieur.
• Server - Server HTTP qui vous permet d'utiliser Tranquility sans développer une application JVM.
• Samza - Tranquility comprend un Samza SystemProducer.
• Spark - Tranquility fonctionne avec RDDS et DSTREAMS.
• Storm - La tranquillité comprend un boulon de tempête et un état trident.
• Kafka - Application pour pousser les messages de Kafka dans Druid via Tranquility.
• Flink - Tranquility comprend un évier Flink.

Obtenir une tranquillité avec Maven

Tranquility Core, Samza, Spark, Storm et Flink sont censés être inclus dans une application que vous écrivez. Ces modules sont hébergés sur Maven Central pour les rendre faciles à inclure. Les versions stables actuelles sont:

< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-core_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >
< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-samza_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >
< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-spark_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >
< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-storm_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >
< dependency >
  < groupId >io.druid</ groupId >
  < artifactId >tranquility-flink_2.11</ artifactId >
  < version >0.8.2</ version >
</ dependency >

Il vous suffit d'inclure les modules que vous utilisez réellement.

Tous les modules de tranquillité sont conçus pour Scala 2.11.

Cette version est conçue pour fonctionner avec Druid 0.7.x et 0.8.x. Si vous utilisez Druid 0.6.x, vous voudrez peut-être utiliser Tranquility V0.3.2, qui est la version la plus récente conçue pour une utilisation avec Druid 0.6.x.

La tranquillité est construite avec SBT. Si vous souhaitez construire les pots vous-même, vous pouvez exécuter sbt +package . Pour construire un tarball de distribution, exécutez sbt ++2.11.8 'project distribution' universal:packageZipTarball .

Distribution téléchargeable

La distribution téléchargeable Tranquility comprend les programmes Server et Kafka, qui sont des programmes autonomes qui peuvent être utilisés sans écrire de code. Vous pouvez télécharger la distribution et les exécuter directement. La distribution comprend également les artefacts API de base, si vous préférez les télécharger plutôt que de les obtenir via Maven.

La distribution actuelle est: Tranquility-Distribution-0.8.2.

Pour l'utiliser, téléchargez-le d'abord, puis le déballer dans votre répertoire de choix en exécutant tar -xzf tranquility-distribution-0.8.2.tgz .

Comment contribuer

Voir contribution.md.