Flask app with spark

from pyspark import SparkContext
sc = SparkContext('local')

from flask import Flask, request
app = Flask(__name__)

@app.route('/whateverYouWant', methods=['POST'])  #can set first param to '/'

def toyFunction():
    posted_data = sc.parallelize([request.get_data()])
    return str(posted_data.collect()[0])

if __name__ == '__main_':
    app.run(port=8080)    #note set to 8080!

Source: stackoverflow.com

Similar codes

0 vote346 views1 answer
Mute button tkinter
Python
21 votes380 views3 answers
Creating venv python3
Python
0 vote354 views1 answer
Concatenate dataframes using one column
Python
0 vote362 views1 answer
How to convert cost to float in python
Python
1 vote368 views1 answer
Python saveAsTextFile
Python
31 votes353 views4 answers
Python remove nan rows
Python
8 votes346 views1 answer
Module to read keyboard
Python
23 votes343 views6 answers
Python decorator
Python
0 vote346 views1 answer
Python urlopen parameters
Python
0 vote313 views1 answer
Install formio data python library
Python