scala - javax.mail.AuthenticationFailedException

Question

Mein Ziel ist es, einen Datenrahmen per E-Mail zu senden. unten ist mein Stück Code:

import javax.mail._ 
import javax.mail.internet._ 
import org.apache.spark.{SparkConf, SparkContext} 

object EmailAlert { 
def main(args: Array[String]): Unit = { 

val sparkConf = new SparkConf().setAppName("E-mail Alert").setMaster("local") 
val sc = new SparkContext(sparkConf) 
var bodyText = "Test mail" 

// Set up the mail object 
val properties = System.getProperties 
properties.put("mail.smtp.host", "email-smtp.us-east-1.amazonaws.com") 
properties.put("mail.smtp.user", "********"); 
properties.put("mail.smtp.password", "********"); 
properties.put("mail.smtp.auth", "true"); 
properties.put("mail.smtp.port", "587") 
properties.put("mail.smtp.starttls.enable", "true"); 
val session = Session.getInstance(properties) 
val message = new MimeMessage(session) 

def getPasswordAuthentication(username:String, password:String):Authenticator= 
{ 
    new Authenticator(){ 
    override def getPasswordAuthentication():PasswordAuthentication = { 
     new PasswordAuthentication(username, password); 
    }} 
} 

// Set the from, to, subject, body text 
message.setFrom(new InternetAddress("no-reply@****.com")) 
message.setRecipients(Message.RecipientType.TO, "ajayv@****.com") 
message.setSubject("Count of DeviceIDs we are sent daily") 
message.setText(bodyText) 

// And send it 
Transport.send(message) 
    } 
} 

aber ich die folgenden Fehler, wenn ich den Code ausführen:

Exception in thread "main" javax.mail.AuthenticationFailedException

was Vermisse ich hier.

Answer 1

Ich muss die Session-Authentifizierung übergeben, das, was ich ist bin verpasst, Below-Code für mich gearbeitet:

val sparkConf = new SparkConf().setAppName("E-mail Alert").setMaster("local") 
val sc = new SparkContext(sparkConf) 
var bodyText = "Test mail" 
val username = "*****************" 
val password = "************************" 
val smtpHost = "email-smtp.us-east-1.amazonaws.com" 

// Set up the mail object 
val properties = System.getProperties 
properties.put("mail.smtp.host", smtpHost) 
properties.put("mail.smtp.user", username); 
properties.put("mail.smtp.password", password); 
properties.put("mail.smtp.auth", "true"); 
properties.put("mail.smtp.port", "587") 
properties.put("mail.smtp.starttls.enable", "true"); 

val auth:Authenticator = new Authenticator() { 
    override def getPasswordAuthentication = new 
     PasswordAuthentication(username, password) 
} 

val session = Session.getInstance(properties,auth) 
val message = new MimeMessage(session) 

// Set the from, to, subject, body text 
message.setFrom(new InternetAddress("no-reply@*****.com")) 
message.setRecipients(Message.RecipientType.TO, "ajayv@****.com") 
message.setSubject("Count of DeviceIDs we are sent daily") 
message.setText(bodyText) 

// And send it 
Transport.send(message) 

Answer 2

Sie sich von der Authenticator befreien (die überhaupt nicht verwendet werden) und die mail.smtp.user, mail.smtp.password und mail.smtp.auth Eigenschaften, dann die Transport.send method that takes a user name and password nennen. Wenn es immer noch nicht funktioniert, poste die JavaMail debug output.