GCP Cloud Logging
To set up log forwarding from GCP Cloud Logging to Apica Ascent, you must:
- Create a user-managed service account
- Create a Cloud Pub/Sub topic
- Create a log sink and subscribe it to the Pub/Sub topic
- Create a VM for Logstash
The examples in this document use the
gcloud command-line interface. Google Cloud APIs must be enabled through the Services and APIs page in the console before they can be used with gcloud. To perform the steps in this tutorial, enable the following APIs:- Compute Engine
- Pub/Sub
- Identity and Access Management (IAM)
- Cloud Logging
Activate and login to the Cloud Shell. Create a service account to attach to the VM
The commands use project name
gcp-customer-1.Replace it with a valid project name from the target account.gcloud iam service-accounts create logstash --display-name="Logstash to Apica Ascent"
Provide IAM permissions allowing the new service account to access Pub/Sub using the
pubsub.subscriber role.gcloud projects add-iam-policy-binding gcp-customer-1 \
--member serviceAccount:[email protected] \
--role roles/pubsub.subscriber
//Replace the customer name 'gcp-customer-1' with a valid one
Create a Pub/Sub topic where Cloud Logging will send events to be picked up by Logstash using the following command.
gcloud pubsub topics create apica-ascent-topic
Next, create a subscription by running the following command.
gcloud pubsub subscriptions create logstash-sub --topic=apica-ascent-topic \
--topic-project=gcp-customer-1
gcloud logging sinks create \
logstash-sink pubsub.googleapis.com/projects/gcp-customer-1/topics/apica-ascent-topic
//Response
Created [https://logging.googleapis.com/v2/projects/scalesec-dev/sinks/logstash-sink].
Please remember to grant `serviceAccount:p35[email protected]` Pub/Sub
Publisher role to the topic.
More information about sinks can be found at /logging/docs/export/
The second part of the output is a reminder to verify that the service account used by Cloud Logging has permission to publish events to the Pub/Sub topic.
gcloud beta pubsub topics add-iam-policy-binding apica-ascent-topic \
--member serviceAccount:[email protected] \
--role roles/pubsub.publisher
You can now launch the Apica Ascent GCP PubSub App extension and pull logs directly from the created topic and subscription. Please refer to the documenation on how to do so.
Create a VM to run
logstash to pull logs from the Pub/Sub logging sink and send them to Apica Ascent:gcloud compute --project=gcp-customer-1 instances create logstash \
--zone=us-west1-a \
--machine-type=n1-standard-1 \
--subnet=default \
--s[email protected] \
--scopes="https://www.googleapis.com/auth/cloud-platform" \
--image-family=ubuntu-1804-lts \
--image-project=ubuntu-os-cloud \
--boot-disk-size=10GB \
--boot-disk-type=pd-ssd \
--boot-disk-device-name=logstash
Once the VM is running, SSH into the VM and then configure Logstash, as shown below.
gcloud compute ssh logstash --zone us-west1-a
sudo apt-get update
sudo apt-get -y upgrade
sudo apt -y install openjdk-8-jre-headless
echo "export JAVA_HOME=\"/usr/lib/jvm/java-8-openjdk-amd64\"" >> ~/.profile
sudo reboot
After a few moments, the VM will complete its reboot and can be accessed again via
gcloud.gcloud compute ssh logstash --zone us-west1-a
Install Logstash as shown below.
wget -qO - https://artifacts.elastic.co/GPG-KEY-elasticsearch | sudo apt-key add -
echo "deb https://artifacts.elastic.co/packages/6.x/apt stable main" | sudo tee -a /etc/apt/sources.list.d/elastic-6.x.list
sudo apt-get update
sudo apt-get install logstash
# Install Logstash google_pubsub plugin
cd /usr/share/logstash
sudo -u root sudo -u logstash bin/logstash-plugin install logstash-input-google_pubsub
Logstash comes with no default configuration. Create a new file
/etc/logstash/conf.d/logstash.conf with the below contents, modifying values as needed:input
{
google_pubsub {
project_id => "gcp-customer-1"
topic => "logiq-topic"
subscription => "logstash-sub"
include_metadata => true
codec => "json"
}
}
filter {
json {
source => "message"
}
mutate {
add_field => { "namespace" => "%{[resource][labels][project_id]}" }
add_field => { "cluster_id" => "dev" }
add_field => { "app_name" => "%{[resource][labels][service_name]}" }
add_field => { "proc_id" => "%{[resource][labels][revision_name]}" }
}
}
output {
http {
url => "http://<apica-ascent-endpoint>.logiq.ai/v1/json_batch"
headers => { "Authorization" => "Bearer <SECURE_INGEST_TOKEN>" }
http_method => "post"
format => "json_batch"
content_type => "json_batch"
pool_max => 2000
pool_max_per_route => 100
socket_timeout => 300
}
}
Autopilot is a new mode of operation in Google Kubernetes Engine (GKE) that is designed to reduce the operational cost of managing clusters, optimize your clusters for production, and yield higher workload availability, use the below configuration on Logstash configuration to forward logs to Apica Ascent.
input
{
google_pubsub {
project_id => "gcp-customer-1"
topic => "logiq-topic"
subscription => "logstash-sub"
include_metadata => true
codec => "json"
}
}
filter {
json {
source => "message"
}
if [resource][type] == "k8s_container" {
mutate {
add_field => { "namespace" => "%{[resource][labels][namespace_name]}" }
add_field => { "cluster_id" => "%{[resource][labels][cluster_name]}" }
add_field => { "app_name" => "%{[resource][labels][container_name]}" }
add_field => { "proc_id" => "%{[resource][labels][pod_name]}" }
}
if [textPayload] {
mutate {
add_field => { "message" => "%{[textPayload]}" }
}
}
if [jsonPayload][message] {
mutate {
add_field => { "message" => "%{[jsonPayload][message]}" }
}
}
}
else if [resource][type] == "k8s_pod" {
mutate {
add_field => { "namespace" => "%{[resource][labels][namespace_name]}" }
add_field => { "cluster_id" => "%{[resource][labels][cluster_name]}" }
add_field => { "app_name" => "k8s_pod" }
add_field => { "proc_id" => "%{[resource][labels][pod_name]}" }
}
if [message] {
mutate {
add_field => { "message" => "%{[message]}" }
}
}
} else if [resource][type] == "k8s_node" {
mutate {
add_field => { "namespace" => "k8s_node" }
add_field => { "cluster_id" => "%{[resource][labels][cluster_name]}" }
add_field => { "app_name" => "k8s_node" }
add_field => { "proc_id" => "%{[resource][labels][node_name]}" }
}
if [jsonPayload][MESSAGE] {
mutate {
add_field => { "message" => "%{[jsonPayload][MESSAGE]}" }
}
}
} else if [resource][type] == "k8s_cluster" {
mutate {
add_field => { "namespace" => "k8s_cluster" }
add_field => { "cluster_id" => "%{[resource][labels][cluster_name]}" }
add_field => { "app_name" => "k8s_cluster" }
add_field => { "proc_id" => "-" }
}
}
# There could be other resource types you may want to add if you want to
# pull more logs.
}
output {
http {
url => "http://<logiq-endpoint>.logiq.ai/v1/json_batch"
headers => { "Authorization" => "Bearer <SECURE_INGEST_TOKEN>" }
http_method => "post"
format => "json_batch"
content_type => "json_batch"
pool_max => 2000
pool_max_per_route => 100
socket_timeout => 300
}
}
The mappings for k8s_node, k8s_pod, k8s_cluster can further be refined by mapping into the json logs from cloud logging. The above mapping is an example on how you can use flexible mappings to suite your needs.
You can obtain an ingest token from the Apica Ascent UI as described here. You can customize the
namespace and cluster_id in the Logstash configuration based on your needs.Your GCP Cloud Logging logs will now be forwarded to your Apica Ascent instance. See the Explore Section to view the logs.
If you are running logstash in a VM outside of GCE, you need to provide the service account token in the logstash configuration as well.
input {
google_pubsub {
project_id => "my-project-1234"
topic => "logstash-input-dev"
subscription => "logstash-sub"
# the GCP service account's JSON key file below.
json_key_file => "/path/to/service/account/token/pkey.json"
}
}
Last modified 1mo ago