skip to main content
10.1145/3230599.3230618acmotherconferencesArticle/Chapter ViewAbstractPublication PagesceriConference Proceedingsconference-collections
research-article

Building Python-Based Topologies for Massive Processing of Social Media Data in Real Time

Published: 26 June 2018 Publication History

Abstract

In this paper we propose a streaming approach for real-time processing of huge amounts of data. CATENAE is a library for easy building and execution of Python topologies (e.g., web crawler, classifier). Topologies are designed for their deployment inside Docker containers and, thus, horizontal scaling, granular resource assignment and isolation can be achieved easily. Furthermore, micromodules can have its own dependencies (including the Python version), allowing the user to limit resources such as CPU or memory by instance. We describe an implementation of a use case composed of two topologies: (1) a crawler for tracking users in social media and (2) an early risk detector of depression. We also explain how CATENAE topologies can be connected to non-Python systems.

References

[1]
About Reddit. 2018. https://www.redditinc.com/. {Online; accessed April, 2018}.
[2]
Aerospike. 2018. https://www.aerospike.com/. {Online; accessed April, 2018}.
[3]
Apache Hadoop. 2018. https://hadoop.apache.org/. {Online; accessed April, 2018}.
[4]
Apache Kafka. 2018. https://kafka.apache.org/. {Online; accessed April, 2018}.
[5]
Apache Storm. 2018. https://storm.apache.org/. {Online; accessed April, 2018}.
[6]
Apache Thrift. 2018. https://thrift.apache.org/. {Online; accessed April, 2018}.
[7]
J. Dean and S. Ghemawat. 2004. MapReduce: Simplified Data Processing on Large Clusters. In Symposium on Operating System Design and Implementation. 10--10.
[8]
Docker. 2018. http://www.docker.com/. {Online; accessed April, 2018}.
[9]
B. Hindman, A. Konwinski, M. Zaharia, A. Ghodsi, A. D. Joseph, R. Katz, S. Shenker, and I. Stoica. 2011. Mesos: A Platform for Fine-grained Resource Sharing in the Data Center. In Proc. of the 8th USENIX Conference on Networked Systems Design and Implementation. USENIX Association, 295--308.
[10]
D. Losada and F. Crestani. 2016. A Test Collection for Research on Depression and Language Use. In Proc. of CLEF. 28--39.
[11]
D. Losada, F. Crestani, and J. Parapar. 2017. eRISK 2017: CLEF Lab on Early Risk Prediction on the Internet: Experimental Foundations. In Proc. of CLEF. 346--360.
[12]
R. Martínez-Castaño, J. C. Pichel, and P. Gamallo. 2018. Polypus: a Big Data Self-Deployable Architecture for Microblogging Text Extraction and Real-Time Sentiment Analysis. CoRR abs/1801.03710 (2018). arXiv:1801.03710
[13]
R. Martínez-Castaño, J. C. Pichel, D. E. Losada, and F. Crestani. 2018. A Micromodule Approach for Building Real-Time Systems with Python-Based Models: Application to Early Risk Detection of Depression on Social Media. In Advances in Information Retrieval. Springer International Publishing, 801--805.
[14]
Reddit on Alexa. 2018. https://www.alexa.com/siteinfo/reddit.com/. {Online; accessed April, 2018}.
[15]
V. K. Vavilapalli, A. C. Murthy, C. Douglas, S. Agarwal, M. Konar, R. Evans, T. Graves, J. Lowe, H. Shah, S. Seth, B. Saha, C. Curino, O. O'Malley, S. Radia, B. Reed, and E. Baldeschwieler. 2013. Apache Hadoop YARN: Yet Another Resource Negotiator. In Proc. of the 4th Annual Symposium on Cloud Computing (SOCC). 5:1--5:16.
[16]
M. Zaharia, M. Chowdhury, M.J. Franklin, S. Shenker, and I. Stoica. 2010. Spark: Cluster Computing with Working Sets. In Proc. of the 2nd USENIX Conf. on Hot Topics in Cloud Computing (HotCloud). 10--10.

Cited By

View all

Recommendations

Comments

Information & Contributors

Information

Published In

cover image ACM Other conferences
CERI '18: Proceedings of the 5th Spanish Conference on Information Retrieval
June 2018
91 pages
ISBN:9781450365437
DOI:10.1145/3230599
Permission to make digital or hard copies of all or part of this work for personal or classroom use is granted without fee provided that copies are not made or distributed for profit or commercial advantage and that copies bear this notice and the full citation on the first page. Copyrights for components of this work owned by others than the author(s) must be honored. Abstracting with credit is permitted. To copy otherwise, or republish, to post on servers or to redistribute to lists, requires prior specific permission and/or a fee. Request permissions from [email protected].

Publisher

Association for Computing Machinery

New York, NY, United States

Publication History

Published: 26 June 2018

Permissions

Request permissions for this article.

Check for updates

Author Tags

  1. Depression
  2. Docker
  3. Python
  4. Real-Time Processing
  5. Social Media
  6. Stream Processing
  7. Text Mining

Qualifiers

  • Research-article
  • Research
  • Refereed limited

Conference

CERI '18

Acceptance Rates

CERI '18 Paper Acceptance Rate 18 of 24 submissions, 75%;
Overall Acceptance Rate 36 of 51 submissions, 71%

Contributors

Other Metrics

Bibliometrics & Citations

Bibliometrics

Article Metrics

  • Downloads (Last 12 months)3
  • Downloads (Last 6 weeks)1
Reflects downloads up to 14 Sep 2024

Other Metrics

Citations

Cited By

View all

View Options

Get Access

Login options

View options

PDF

View or Download as a PDF file.

PDF

eReader

View online with eReader.

eReader

Media

Figures

Other

Tables

Share

Share

Share this Publication link

Share on social media