Как запустить Django и приложение Spark - PullRequest
0 голосов
/ 27 марта 2020

Я работаю над приложением Spark и хочу создать API отдыха в Django, ниже мой код

from django.shortcuts import render
from django.http import Http404
from rest_framework.views import APIView
from rest_framework.decorators import api_view
from rest_framework.response import Response
from rest_framework import status
from django.http import JsonResponse
from django.core import serializers
from django.conf import settings
import json
from pyspark import SparkContext, SparkConf, SQLContext


sc = SparkContext()
sql = SQLContext(sc)

df = Sql.read.format("jdbc").options(
        url = "jdbc:mysql://127.0.0.1:3306/demo",
        driver = "com.mysql.cj.jdbc.Driver",
        dbtable = "tablename",
        user = "xyz",
        password = "abc" 
).load()

totalrecords = df.count()


# Create your views here.
@api_view(["GET"])
def Demo(self):
    try:
        a = str(totalrecords)
        return JsonResponse(a,safe=False)
    except ValueError as e:
        return Response(e.args[0],status.HTTP_400_BAD_REQUEST)

Я хочу знать, как я буду запускать этот код, так как у меня есть напрямую пробовал "python manage.py runserver", который не работает, так как запустить эту искру и django с django api и spark-submit со всем необходимым файлом JAR-файла?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...