Olá comunidade.
Estou tentando conectar os dados do meu bot ao Power Bi/Databricks
Mas não consigo encontrar muita informação sobre isso :(
Você conhece alguma documentação que possa ajudar?
Muito obrigado.
Boa noite
Da uma olhada nesse texto abaixo talvez te ajude :
Conectar o Blip ao Power BI (Usando API do Blip)
Podemos usar Node.js para chamar a API do Blip e enviar os dados para o Power BI.
Passos:
-
Obter o Token do Blip
- Vá até o Blip Portal → Configurações → Chaves de Autenticação
- Copie o Authorization Key
-
Criar um script Node.js para buscar os dados da API do Blip
const axios = require("axios");
// Configuração da API do Blip
const BLIP_API_URL = "https://http.msging.net/commands";
const BLIP_AUTH_KEY = "Key SEU_TOKEN_AQUI"; // Substitua pelo seu token
async function getBlipAnalytics() {
try {
const response = await axios.post(
BLIP_API_URL,
{
id: new Date().getTime().toString(),
to: "[email protected]",
method: "get",
uri: "/event-track"
},
{
headers: {
"Content-Type": "application/json",
Authorization: BLIP_AUTH_KEY
}
}
);
console.log("Dados do Blip:", response.data);
return response.data;
} catch (error) {
console.error("Erro ao buscar dados do Blip:", error);
}
}
// Chamar a função
getBlipAnalytics();
Enviar os dados para o Power BI
O Power BI pode receber dados via Streaming Dataset. Para isso:
- Crie um dataset no Power BI (via API de Streaming).
- Envie os dados do Blip para o Power BI.
const POWER_BI_URL = "https://api.powerbi.com/beta/SUA_URL_STREAMING"; // Substitua pela URL do Power BI
async function sendToPowerBI(data) {
try {
const response = await axios.post(POWER_BI_URL, data, {
headers: { "Content-Type": "application/json" }
});
console.log("Dados enviados ao Power BI:", response.status);
} catch (error) {
console.error("Erro ao enviar para Power BI:", error);
}
}
// Chamar a função para buscar do Blip e enviar para o Power BI
getBlipAnalytics().then(data => {
if (data) sendToPowerBI(data);
});
Conectar o Blip ao Databricks (Usando AWS S3 ou Azure Blob)
O Databricks pode ler dados de AWS S3 ou Azure Blob Storage, então vamos enviar os dados do Blip para um desses serviços.
Enviar os dados para AWS S3
const AWS = require("aws-sdk");
// Configurar AWS S3
const s3 = new AWS.S3({
accessKeyId: "SEU_ACCESS_KEY",
secretAccessKey: "SEU_SECRET_KEY",
region: "us-east-1"
});
async function sendToS3(data) {
const params = {
Bucket: "meu-bucket",
Key: `blip-data-${Date.now()}.json`,
Body: JSON.stringify(data),
ContentType: "application/json"
};
try {
await s3.upload(params).promise();
console.log("Dados enviados para S3");
} catch (error) {
console.error("Erro ao enviar para S3:", error);
}
}
// Chamar a função para buscar do Blip e enviar para S3
getBlipAnalytics().then(data => {
if (data) sendToS3(data);
});
Ler os dados no Databricks
No Databricks, você pode ler os dados do S3 com PySpark:
df = spark.read.json("s3://meu-bucket/blip-data-*.json")
display(df)
Se estiver usando Azure Blob Storage, pode usar:
df = spark.read.format("csv").load("wasbs://[email protected]")
display(df)
Conclusão
Para Power BI → Pegamos os dados do Blip via API e enviamos para o Power BI Streaming Dataset.
Para Databricks → Enviamos os dados do Blip para AWS S3 (ou Azure Blob) e lemos no Databricks com PySpark.
Comente
Enter your E-mail address. We'll send you an e-mail with instructions to reset your password.