public void loadToFirebase() {
/** * { "rules":{ ".read":true, ".write":"auth.uid === 'my-service-worker'" } } */
try {
//load data java.io.FileReader reader =
new java.io.FileReader(new File(JSON_CRAWLED_DATA_FILE));
Type listType = new TypeToken<List<MtprotoProxy>>() {
}.getType();
List<MtprotoProxy> data = gson.fromJson(reader, listType);
FileInputStream serviceAccount =
new FileInputStream(
"resources/firebase/mtprotolist-firebase-adminsdk-difsq-7d5482a255.json");
Map<String, Object> auth = new HashMap<>();
auth.put("uid", "my-service-worker");
FirebaseOptions options = new FirebaseOptions.Builder()
.setCredentials(
GoogleCredentials.fromStream(serviceAccount)
//FirebaseCredentials.fromCertificate(serviceAccount) )
.setDatabaseUrl("https://mtprotolist.firebaseio.com")
.setDatabaseAuthVariableOverride(
auth
//null )
.build();
FirebaseApp.initializeApp(options);
// As an admin, the app has access to read and write all data,
//regardless of Security Rules DatabaseReference ref = FirebaseDatabase.getInstance()
.getReference("");
// ref.addValueEventListener(new ValueEventListener() {// @Override// public void onDataChange(DataSnapshot dataSnapshot) {// Object document = dataSnapshot.getValue();// log.info(document);// }//// @Override// public void onCancelled(DatabaseError error) {// log.info(error.getMessage());// }// });// ref.addListenerForSingleValueEvent(new ValueEventListener() {// @Override// public void onDataChange(DataSnapshot dataSnapshot) {// Object document = dataSnapshot.getValue();// log.info(document);// }//// @Override// public void onCancelled(DatabaseError error) {// log.info(error.getMessage());// }// });
ref.setValue(data, new DatabaseReference.CompletionListener() {
@Override public void onComplete(DatabaseError databaseError,
DatabaseReference databaseReference) {
log.info(databaseError);
}
});
} catch (Exception e) {
log.error(e.getMessage());
}
try {
Thread.sleep(17000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
Комментариев нет:
Отправить комментарий