Apache Storm este popular datorită funcțiilor de procesare în timp real și multe organizații l-au implementat ca parte a sistemului lor din acest motiv. Să aruncăm o privire asupra modului în care organizațiile integrează Apache Storm.
Cazuri de utilizare Apache Storm:
Stare de nervozitate
Storm este folosit pentru a alimenta o varietate de sisteme Twitter, cum ar fi analize în timp real, personalizare, căutare, optimizare a veniturilor și multe altele. Apache Storm se asimilează cu restul infrastructurii Twitter, care include sisteme de baze de date precum Cassandra, Memcached etc., infrastructura de mesagerie, Mesos și sistemele de monitorizare și alertare. Planificatorul de izolare al Storm face posibilă utilizarea aceluiași cluster pentru aplicații de producție și aplicații în dezvoltare. Oferă un mod eficient de planificare a capacității.
c ++ stl întrebări de interviu
Yahoo!
Yahoo! lucrează la o platformă de nouă generație care permite îmbinarea Big Data și procesarea cu latență redusă. Deși Hadoop este tehnologia principală utilizată aici pentru procesarea în lot, Apache Storm permite procesarea în flux a evenimentelor utilizatorilor, a fluxurilor de conținut și a jurnalelor de aplicații.
Infochimps
Infochimps folosește Apache Storm ca sursă pentru unul dintre cele trei servicii de date cloud - Servicii de livrare de date (DDS), care folosește Storm pentru a oferi o colectare de date, transport și servicii de cloud complexe de procesare in-stream tolerante la erori și scalabile liniar. . Similar cu Hadoop, care furnizează ETL pe lot și procesare analitică pe scară largă, DDS oferă, de asemenea, ETL în timp real și procesare pe scară largă în timp real.
Flipboard
Flipboard este un singur loc unde puteți explora, colecta și partaja știri care vă interesează. Flipboard folosește Storm pentru o gamă largă de servicii precum căutare de conținut, analize în timp real, fluxuri de reviste personalizate etc. Apache Storm este integrat cu infrastructura care include sisteme precum ElasticSearch, Hadoop, HBase și HDFS, pentru a crea o platformă de date foarte scalabilă.
Ooyala
Ooyala este o companie privată, susținută de întreprinderi, care oferă produse și servicii de tehnologie video online pentru unele dintre cele mai mari rețele, mărci și companii media din lume. Ooyala are un motor de analiză care procesează peste două miliarde de evenimente de analiză în fiecare zi, generat de aproape 200 de milioane de telespectatori din întreaga lume care urmăresc videoclipuri pe un player alimentat de Ooyala. Ooyala folosește Apache Storm pentru a oferi clienților lor, analize de streaming în timp real privind comportamentul de vizionare al consumatorilor și tendințele conținutului digital. Storm permite extragerea rapidă a seturilor lor de date video online pentru a furniza informații de afaceri actuale, cum ar fi vizualizarea modelelor în timp real, sugestii personalizate de conținut, ghiduri de programare și informații valoroase despre modalitățile de creștere a veniturilor.
Taobao
Taobao, cu ajutorul Apache Storm, creează statistici din jurnale și extrage informații utile din statistici în timp real. Jurnalele sunt citite din cozile de mesaje persistente în spouts, procesate și apoi trecute la topologii, pentru a calcula rezultatele necesare. Numărul jurnalului de intrare Taobao variază între 2 milioane și 1,5 miliarde în fiecare zi.
Klout
Klout este o aplicație care folosește analiza social media pentru a-și clasifica bazele utilizatorilor pe influența socială online prin „Klout Score”, care este o valoare numerică cuprinsă între 1 și 100. Klout folosește abstracția Trident încorporată a Apache Storm pentru a crea topologii complexe care transmit fluxul de date de la colectoare de rețea prin Kafka, apoi procesate și scrise pe HDFS.
Noi mergem
Wega este motorul global de metacaută de călătorii, care funcționează în întreaga lume și este utilizat de nenumărați călători pentru a obține mai multe opțiuni de plată mai mică și călătorie mai mare. Wego compară și afișează programarea zborurilor în timp real, disponibilitatea hotelului, prețul și afișează alte site-uri de călătorie din întreaga lume. Aici, Apache Storm transmite date de căutare în timp real a metasearch de la afiliați către utilizatori finali. Conceptele de topologie din Storm rezolvă problemele de concurență și, în același timp, le ajută să integreze, să diseceze și să curețe datele fără încetare. În plus, instrumentele furnizate în Storm permit actualizarea incrementală pentru a-și îmbunătăți datele.
Combustibil pentru racheta
Rocket Fuel oferă o platformă de cumpărare media de top la scara Big Data, care valorifică puterea inteligenței artificiale (AI) pentru a extinde rentabilitatea investiției de marketing în mass-media digitală. Ei construiesc o platformă în timp real deasupra Storm, care imită fluxurile de muncă critice în timp deja existente în conducta ETL bazată pe Hadoop. Această platformă urmărește în timp real afișările, clicurile, conversiile, solicitările de licitare etc.
system.exit (0) poate fi folosit pentru a termina programul.
Navsite
Navsite folosește Apache Storm ca parte a sistemului de monitorizare și audit al jurnalului de evenimente de pe server. Mesajele jurnal de la mii de servere sunt trimise către clusterul RabbitMQ și Storm este folosit pentru a compara fiecare mesaj cu un set de expresii regulate. Dacă există o potrivire, atunci mesajul este trimis unui bolț care stochează date în MongoDB. În acest moment, sunt gestionate 5-10k mesaje pe secundă, însă grupurile RabbitMQ + Storm existente au fost testate până la aproximativ 50k pe secundă.
Există mult mai multe organizații care implementează Apache Storm și se așteaptă și mai multe să se alăture acestui joc, deoarece Apache Storm continuă să fie lider în analize în timp real.
Verificați-ne .