如何解决无法使用 HTTP 客户端访问 REST API
我正在尝试使用 Scala 和 HTTP 客户端库访问 RestAPI(Databricks),但无法获得正确响应。
我正在尝试使用 Bearer token 访问,并且端点是 https://somename.cloud.databricks.com/api/2.0/jobs/runs/list?active_only=true&limit=15。 从 EC2 机器和 AWS 上的 Databricks 集群访问此端点。当我从本地机器(通过 IDE)执行时,相同的代码给出了正确的响应。
代码如下:
def listOutJobs(endpoint:String,givenToken:String):Unit={
val url:URLConnection = new URL(endpoint).openConnection()
val conn:HttpsURLConnection = url.asInstanceOf[HttpsURLConnection]
conn.setRequestProperty("Authorization","Bearer "+givenToken)
conn.setRequestProperty("Content-Type","application/json")
conn.setDoOutput(true)
conn.setRequestMethod("GET")
println(conn.getResponseCode)
val in : BufferedReader = new BufferedReader(new InputStreamReader(conn.getInputStream))
var output : String = ""
val response:StringBuffer = new StringBuffer()
while ( output != null) {
println(output)
response.append(output)
output = in.readLine()
}
conn.getHeaderField("Authorization")
println(conn.getHeaderFields)
in.close()
println("Response:-" + response.toString)
}
即使我也尝试过下面的代码,但都给出了相同的响应。
def callPostMethod(endpoint:String,givenToken:String):Unit={
val httpClient:CloseableHttpClient = HttpClients.createDefault()
val httppost:HttpGet = new HttpGet(endpoint)
httppost.addHeader("Authorization","Bearer "+givenToken)
httppost.addHeader("Content-Type","application/json")
httppost.addHeader("user-agent","Mozilla/5.0")
val response:CloseableHttpResponse = httpClient.execute(httppost)
val statusLine:StatusLine = response.getStatusLine
println(scala.io.source.fromInputStream(response.getEntity.getContent).mkString)
println(statusLine.getStatusCode)
println(statusLine)
httppost.getAllHeaders.foreach(x => x.getElements.foreach(z => z.getName))
}
def AllowRedirect(endpoint:String,givenToken:String):Unit={
val instance:HttpClient = HttpClientBuilder.create().setRedirectStrategy(new
LaxRedirectStrategy()).build()
val httpGet = new HttpGet(endpoint)
httpGet.addHeader("Authorization","Bearer "+givenToken)
httpGet.addHeader("Content-Type","application/json")
val response:HttpResponse = instance.execute(httpGet)
println(response.getStatusLine.getStatusCode)
println(response)
}
下面是 HTML 格式的响应,我得到的响应代码是 200。
<!doctype html>
<html>
<head>
<Meta charset="utf-8"/>
<Meta http-equiv="Content-Language" content="en"/>
<title>Databricks - Sign In</title>
<Meta name="viewport" content="width=960"/>
<link rel="icon" type="image/png" href="/favicon.ico"/>
<Meta http-equiv="content-type" content="text/html; charset=UTF8"/>
<link rel="icon" href="favicon.ico"></head><body><uses-legacy-bootstrap><
div id="login-page"></div>
</uses-legacy-bootstrap>
<script src="login/login.ddb607f5.js"></script></body></html>
有人可以帮助我吗。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。