victortsaitw12’s gists

victortsaitw12 / clusterrolebindings.yml

Created January 9, 2019 15:20 — forked from jimmycuadra/clusterrolebindings.yml

Default RBAC cluster roles and cluster role bindings built into Kubernetes

	apiVersion: v1
	items:
	- apiVersion: rbac.authorization.k8s.io/v1alpha1
	kind: ClusterRoleBinding
	metadata:
	creationTimestamp: 2017-02-23T00:03:51Z
	name: cluster-admin
	namespace: ""
	resourceVersion: "35"
	selfLink: /apis/rbac.authorization.k8s.io/v1alpha1/clusterrolebindingscluster-admin

victortsaitw12 / linebot_ai.js

Last active August 19, 2018 06:05

	'use strict'

	const projectId = process.env.DF_PROJECT_ID;
	const dialogflow = require('dialogflow');
	const Users = require('./users.js');
	const restRequest = require('./restRequest.js');

	class AI {
	constructor() {
	console.log('dialogflow:project_id:' + projectId);

victortsaitw12 / line_bot_indes.js

Last active August 19, 2018 05:57

	'use strict'

	const express = require('express');
	const Linebot = require('./linebot.js');

	const app = express();

	const linebot = new Linebot();
	//const ai = new AI();

victortsaitw12 / line_bot_service.yaml

Last active August 19, 2018 05:54

victortsaitw12 / line_bot_ingress.yaml

Last active August 19, 2018 05:55

	kind: Ingress
	metadata:
	name: fanout-ingress
	annotations:
	kubernetes.io/ingress.global-static-ip-name: -ip
	ingress.kubernetes.io/rewrite-target: /
	kubernetes.io/ingress.allow-http: "false"
	spec:
	tls:
	- hosts:

victortsaitw12 / elastic_k8s_gce.yml

Created August 11, 2018 05:43

	metadata:
	name: elasticsearch
	spec:
	serviceName: elasticsearch-service
	replicas: 1
	template:
	metadata:
	labels:
	role: elasticsearch
	spec:

victortsaitw12 / Elasticsearch_restful.js

Last active August 11, 2018 11:42

	function ElkfetchData(elasticsearch, coin_type) {
	let query_body = {
	"query": {
	"function_score": {
	"query": {
	"multi_match": {
	"query": coin_type,
	"operator": "and",
	"fields": ["title", "content"]
	}

victortsaitw12 / Elasticsearch_scrapy.py

Created August 8, 2018 13:12

	from jpy_currency.items import ArticleItem
	from scrapy.utils.markup import remove_tags

	class ArticleSpider(scrapy.Spider):
	name = "articleSpider"

	def start_requests(self):
	print('start request currency news')
	urls = ['news web site']
	for url in urls:

victortsaitw12 / Elasticsearch_save_news.py

Last active August 8, 2018 12:58

	def saveToELK(item):
	if Utility.elk is None:
	Utility.elk = Elasticsearch(hosts= 'elasticsearch')
	# 檢查如果沒有這個 index 則新增
	if Utility.elk.indices.exists(index='article') is not True:
	res = Utility.elk.indices.create(index="article", body={
	"mappings": {
	"article": {
	"properties": {
	"title": {

victortsaitw12 / kafka_stream_word_count_demo.java

Created August 5, 2018 05:21

	public class WordCount {
	public Topology createTopology(){
	StreamsBuilder builder = new StreamsBuilder();
	// 監聽 Kafka 裡 topic 為 word-count-input 收到的資料
	KStream<String, String> textLines = builder.stream("word-count-input");
	KTable<String, Long> wordCounts = textLines
	// 查看收到的資料值
	.peek((key, value) -> System.out.println(value))
	// 資料值轉成小寫
	.mapValues(textLine -> textLine.toLowerCase())