import synapse.ml

from synapse.ml.cognitive import *

from pyspark.sql.functions import col

input_df = spark.sql("SELECT id,inreplyto,name,userid,emailaddress,subject,comment FROM default.mycomment")

sentiment_df = (TextSentiment()

.setTextCol("comment")

.setLocation("eastus").setEndpoint("#####################")# Fill LangService EndPoint

.setSubscriptionKey("################################")# File LanguageServiceKey

.setOutputCol("sentiment")

.setErrorCol("error")

#.setLanguageCol("language")

.transform(input_df))

display(sentiment_df.withColumn("sentiment",col("sentiment").getItem("document").

getItem("sentences[0].getItem("sentiment")).select("id","inreplyto","name","userid","emailaddress",

"subject","comment", "sentiment"))