Graylog免费和开源的日志管理

/** * This file is part of Graylog2. * * Graylog2 is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * Graylog2 is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with Graylog2. If not, see <http://www.gnu.org/licenses/>. */ package org.graylog2.rest.resources.dashboards; import com.codahale.metrics.MetricRegistry; import com.codahale.metrics.annotation.Timed; import com.google.common.collect.Lists; import com.google.common.collect.Maps; import org.apache.shiro.authz.annotation.RequiresAuthentication; import org.apache.shiro.authz.annotation.RequiresPermissions; import org.graylog2.dashboards.Dashboard; import org.graylog2.dashboards.DashboardImpl; import org.graylog2.dashboards.DashboardRegistry; import org.graylog2.dashboards.DashboardService; import org.graylog2.dashboards.widgets.DashboardWidget; import org.graylog2.dashboards.widgets.InvalidWidgetConfigurationException; import org.graylog2.database.ValidationException; import org.graylog2.indexer.Indexer; import org.graylog2.indexer.searches.timeranges.InvalidRangeParametersException; import org.graylog2.rest.documentation.annotations.*; import org.graylog2.rest.resources.RestResource; import org.graylog2.rest.resources.dashboards.requests.*; import org.graylog2.security.RestPermissions; import org.graylog2.system.activities.Activity; import org.graylog2.system.activities.ActivityWriter; import org.joda.time.DateTime; import org.joda.time.DateTimeZone; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.inject.Inject; import javax.ws.rs.*; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; import java.io.IOException; import java.util.List; import java.util.Map; import java.util.concurrent.ExecutionException; /** * @author Lennart Koopmann <lennart@torch.sh> */ @RequiresAuthentication @Api(value = "Dashboards", description = "Manage dashboards") @Path("/dashboards") public class DashboardsResource extends RestResource { private static final Logger LOG = LoggerFactory.getLogger(DashboardsResource.class); private DashboardService dashboardService; private DashboardRegistry dashboardRegistry; private ActivityWriter activityWriter; private MetricRegistry metricRegistry; private Indexer indexer; @Inject public DashboardsResource(DashboardService dashboardService, DashboardRegistry dashboardRegistry, ActivityWriter activityWriter, MetricRegistry metricRegistry, Indexer indexer) { this.dashboardService = dashboardService; this.dashboardRegistry = dashboardRegistry; this.activityWriter = activityWriter; this.metricRegistry = metricRegistry; this.indexer = indexer; } @POST @Timed @ApiOperation(value = "Create a dashboard") @RequiresPermissions(RestPermissions.DASHBOARDS_CREATE) @Consumes(MediaType.APPLICATION_JSON) @Produces(MediaType.APPLICATION_JSON) @ApiResponses(value = { @ApiResponse(code = 403, message = "Request must be performed against master node.") }) public Response create(@ApiParam(title = "JSON body", required = true) String body) { restrictToMaster(); CreateRequest cr; try { cr = objectMapper.readValue(body, CreateRequest.class); } catch(IOException e) { LOG.error("Error while parsing JSON", e); throw new WebApplicationException(e, Response.Status.BAD_REQUEST); } // Create dashboard. Map<String, Object> dashboardData = Maps.newHashMap(); dashboardData.put("title", cr.title); dashboardData.put("description", cr.description); dashboardData.put("creator_user_id", cr.creatorUserId); dashboardData.put("created_at", new DateTime(DateTimeZone.UTC)); Dashboard dashboard = new DashboardImpl(dashboardData); String id; try { id = dashboardService.save(dashboard); } catch (ValidationException e) { LOG.error("Validation error.", e); throw new WebApplicationException(e, Response.Status.BAD_REQUEST); } dashboardRegistry.add(dashboard); Map<String, Object> result = Maps.newHashMap(); result.put("dashboard_id", id); return Response.status(Response.Status.CREATED).entity(json(result)).build(); } @GET @Timed @ApiOperation(value = "Get a list of all dashboards and all configurations of their widgets.") @Produces(MediaType.APPLICATION_JSON) @ApiResponses(value = { @ApiResponse(code = 403, message = "Request must be performed against master node.") }) public String list() { restrictToMaster(); List<Map<String, Object>> dashboards = Lists.newArrayList(); for (Dashboard dashboard : dashboardService.all()) { if (isPermitted(RestPermissions.DASHBOARDS_READ, dashboard.getId())) { dashboards.add(dashboard.asMap()); } } Map<String, Object> result = Maps.newHashMap(); result.put("total", dashboards.size()); result.put("dashboards", dashboards); return json(result); } @GET @Timed @ApiOperation(value = "Get a single dashboards and all configurations of its widgets.") @Path("/{dashboardId}") @ApiResponses(value = { @ApiResponse(code = 404, message = "Dashboard not found."), @ApiResponse(code = 403, message = "Request must be performed against master node.") }) @Produces(MediaType.APPLICATION_JSON) public String get(@ApiParam(title = "dashboardId", required = true) @PathParam("dashboardId") String dashboardId) { restrictToMaster(); checkPermission(RestPermissions.DASHBOARDS_READ, dashboardId); try { Dashboard dashboard = dashboardService.load(dashboardId); return json(dashboard.asMap()); } catch (org.graylog2.database.NotFoundException e) { throw new WebApplicationException(404); } } @DELETE @Timed @ApiOperation(value = "Delete a dashboard and all its widgets") @Produces(MediaType.APPLICATION_JSON) @Path("/{dashboardId}") @ApiResponses(value = { @ApiResponse(code = 404, message = "Dashboard not found."), @ApiResponse(code = 403, message = "Request must be performed against master node.") }) public Response delete(@ApiParam(title = "dashboardId", required = true) @PathParam("dashboardId") String dashboardId) { restrictToMaster(); checkPermission(RestPermissions.DASHBOARDS_EDIT, dashboardId); try { Dashboard dashboard = dashboardService.load(dashboardId); dashboardRegistry.remove(dashboardId); dashboardService.destroy(dashboard); String msg = "Deleted dashboard <" + dashboard.getId() + ">. Reason: REST request."; LOG.info(msg); activityWriter.write(new Activity(msg, DashboardsResource.class)); } catch (org.graylog2.database.NotFoundException e) { throw new WebApplicationException(404); } return Response.status(Response.Status.fromStatusCode(204)).build(); } @PUT @Timed @ApiOperation(value = "Update the settings of a dashboard.") @Produces(MediaType.APPLICATION_JSON) @Path("/{dashboardId}") @ApiResponses(value = { @ApiResponse(code = 404, message = "Dashboard not