in src/main/java/com/aliyun/openservices/paifeaturestore/FeatureStoreClient.java [65:106]
private void loadProjectData(boolean usePublicAddress) throws Exception {
AK ak = new AK();
ak.setAccessId(this.apiClient.getConfiguration().getConfig().getAccessKeyId());
ak.setAccessKey(this.apiClient.getConfiguration().getConfig().getAccessKeySecret());
Map<String, Project> projectMap = new HashMap<>();
ListProjectResponse listProjectResponse = this.apiClient.getFsProjectApi().ListProjects();
for( com.aliyun.openservices.paifeaturestore.model.Project project : listProjectResponse.getProjects()) {
Datasource datasource = this.apiClient.getDatasourceApi().getDatasourceById(project.getOnlineDatasourceId());
datasource.setAk(ak);
project.setOnlineDataSource(datasource);
Datasource offlineDatasource = this.apiClient.getDatasourceApi().getDatasourceById(project.getOfflineDatasourceId());
offlineDatasource.setAk(ak);
project.setOfflineDataSource(offlineDatasource);
project.createSignature(this.apiClient.getConfiguration().getUsername(), this.apiClient.getConfiguration().getPassword());
Project domainProject = new Project(project,usePublicAddress);
domainProject.setUsePublicAddress(usePublicAddress);
Datasource featureDBDataSource = this.apiClient.getDatasourceApi().getFeatureDBDatasource(offlineDatasource.getWorkspaceId());
if (featureDBDataSource != null) {
domainProject.registerFeatrueDB(featureDBDataSource);
}
domainProject.setApiClient(this.apiClient);
projectMap.put(project.getProjectName(), domainProject);
}
if (projectMap.size() > 0) {
for (Map.Entry<String, Project> entry : projectMap.entrySet()) {
if (!this.projects.containsKey(entry.getKey())) {
this.projects.put(entry.getKey(), entry.getValue());
}
}
}
}