ansible runner把结果写入MongoDB

http://rfyiamcool.blog.51cto.com/1030776/1440624

http://rfyiamcool.blog.51cto.com/1030776/1422263

[email protected]:~/ansible# vi mongo.py

import sys

import pymongo

import ansible.runner

def log(res):

conn = pymongo.Connection(host="localhost", port=27017)

db = conn ["ansible"]

if type(res) == dict:

db.ansible.insert(res)

if __name__ == "__main__":

runner = ansible.runner.Runner(

module_name = ‘shell‘,

module_args = ‘ls -l‘,

pattern = ‘centos5‘,

)

result = runner.run()

log(result)

时间： 2024-10-09 08:17:43

ansible runner把结果写入MongoDB的相关文章

MongoDB 将Json数据直接写入MongoDB的方法

Json转Bson MongoDB中是以Bson数据格式进行存储的,Json字符串没有办法直接写入MongoDB 可以将Json字符串转换成DBObject或者Document,然后写入MongoDB 1.将Json字符转换成com.mongodb.DBObject(准确的说是BasicDBObject) scala版本 import com.mongodb.DBObject import com.mongodb.casbah.{MongoClient, MongoCollection} imp

python日志，支持彩色打印和文件大小切片写入和写入mongodb

支持不同logger name的日志写入不同的文件,不同logger name日志写入不同的mongodb 的collection.LogManager比较容易调用,因为里面的内部方法全都使用了下划线,使用了下划线的就是保护和私有方法不需要外界调用,也不需要看懂他,在调用时候pycharm不会自动补全提示这些带下划线的无关方法了,只暴露了get_and_add_handlers和get_without_handlers两个可能需要调用的方法,pyrcharm可以自动补全这两个方法. 主要思路和模

scrapy中把数据写入mongodb

1.setting.py中打开管道 ITEM_PIPELINES = { # 'tianmao.pipelines.TianmaoPipeline': 300, } 2.setting.py中写入mongodb配置 # mongodb HOST = "127.0.0.1" # 服务器地址 PORT = 27017 # mongo默认端口号 USER = "用户名" PWD = "密码" DB = "数据库名" TABLE =

Logstash写入MongoDB数据库

1. 列出logstash-plugins bin/logstash-plugin list****** logstash-output-kafkalogstash-output-nagioslogstash-output-nulllogstash-output-pagerdutylogstash-output-pipelogstash-output-rabbitmqlogstash-output-redis ****** 2. 根据output格式安装mongodb的output的plugin

python爬取大众点评并写入mongodb数据库和redis数据库

抓取大众点评首页左侧信息,如图: 我们要实现把中文名字都存到mongodb,而每个链接存入redis数据库. 因为将数据存到mongodb时每一个信息都会有一个对应的id,那样就方便我们存入redis可以不出错. # -*- coding: utf-8 -*- import re from urllib.request import urlopen from urllib.request import Request from bs4 import BeautifulSoup from lxml

python 读取单所有json数据写入mongodb(单个)

<--------------主函数-------------------> from pymongo import MongoClientfrom bson.objectid import ObjectIdfrom read_json import read def mongoclient(): client = MongoClient('127.0.0.1', 27017) db = client.test collection = db.test # collection.insert(

tornado+ansible+twisted+mongodb运维自动化系统开发(二)

源码: #!/usr/bin/env python #coding:utf-8 import os.path import tornado.locale import tornado.httpserver import tornado.ioloop import tornado.options import tornado.web from tornado.options import define, options import pymongo define("port", defa

ansible + tornado + MongoDB

http://blog.csdn.net/smallfish1983/article/details/38078019 照着上面那哥们写的,初学,不要吐血,基本功能实现了. [email protected]:~/ansible/tornado# tree.├── templates│ ├── index.html│ └── result.html└── test.py [email protected]:~/ansible/tornado# cat test.py #coding:ut

ansible调用callbacks插件实现结果nosql输出回调

前言: ansible的结果默认是输出到cli终端和日志里面的,用惯了saltsatck的returners数据回调后,也很是喜欢ansible也有,一开始不知道有这个功能,自己也简单实现了这样的功能. 我的实现方式是,在模块里面做一些输出的逻辑.当使用ansible runner api的时候,是在后面runner代码,最后加了一段往redis输出的逻辑. 这里实现数据的输出有些独特,但是只能是在模块和 api方面搞 . 如果是用playbook的话,按照我以前的思路的话,再继续改ansbil